godfreyhe commented on a change in pull request #12577:
URL: https://github.com/apache/flink/pull/12577#discussion_r439919019
##########
File path: docs/try-flink/table_api.md
##########
@@ -123,11 +123,14 @@ tEnv.registerTableSource("transactions", new
BoundedTransactionTableSource());
tEnv.registerTableSink("spend_report", new SpendReportTableSink());
tEnv.registerFunction("truncateDateToHour", new TruncateDateToHour());
-tEnv
- .scan("transactions")
- .insertInto("spend_report");
-
-env.execute("Spend Report");
+// build table program
+Table table = tEnv.scan("transactions");
+
+// trigger execution
+TableResult tableResult = table.executeInsert("spend_report");
Review comment:
There are `The Query` step and `Execute` step in `Breaking Down The
Code` section. This design is for these steps.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
