This is an automated email from the ASF dual-hosted git repository. amaliujia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new fae9067 Update walkthrough.md new cf6bb3d Merge pull request #12052 from dhodun/patch-1 fae9067 is described below commit fae906762d7d5c3f7741bc526075ac59b3a0b9da Author: dhodun <dho...@google.com> AuthorDate: Mon Jun 22 14:39:11 2020 -0400 Update walkthrough.md Fairly sure .setRowSchema() is required in this case. --- website/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 3733324..a02e14c 100644 --- a/website/www/site/content/en/documentation/dsls/sql/walkthrough.md +++ b/website/www/site/content/en/documentation/dsls/sql/walkthrough.md @@ -97,7 +97,7 @@ A `PCollection<Row>` can be obtained multiple ways, for example: // Output the Row representing the current POJO c.output(appRow); } - })); + })).setRowSchema(appSchema); {{< /highlight >}} - **As an output of another `SqlTransform`**. Details in the next section.