From d57e687348a6428b4c5f4ceb858bd66ed3ea428b Mon Sep 17 00:00:00 2001 From: lam206 <81622933+lam206@users.noreply.github.com> Date: Thu, 13 Jan 2022 23:00:04 +0100 Subject: [PATCH] Update walkthrough.md Fixed naming error that leads to a ParseException. "appId" is the name of the field, but then in the query it erroneously said id in the WHERE. --- .../www/site/content/en/documentation/dsls/sql/walkthrough.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/website/www/site/content/en/documentation/dsls/sql/walkthrough.md b/website/www/site/content/en/documentation/dsls/sql/walkthrough.md index 21aa8db3d891..30c45cc66a1a 100644 --- a/website/www/site/content/en/documentation/dsls/sql/walkthrough.md +++ b/website/www/site/content/en/documentation/dsls/sql/walkthrough.md @@ -117,7 +117,7 @@ to either a single `PCollection` or a `PCollectionTuple` which holds multiple SqlTransform.query( "SELECT appId, description, rowtime " + "FROM PCOLLECTION " - + "WHERE id=1")); + + "WHERE appId=1")); {{< /highlight >}} - when applying to a `PCollectionTuple`, the tuple tag for each `PCollection` in the tuple defines the table name that may be used to query it. Note that table names are bound to the specific `PCollectionTuple`, and thus are only valid in the context of queries applied to it.