Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r139468366 --- Diff: docs/dev/table/common.md --- @@ -387,6 +433,59 @@ Table revenue = tableEnv.sql(""" </div> </div> +The following example shows how to specify a update query to insert the result to a registered Table. + +<div class="codetabs" markdown="1"> +<div data-lang="java" markdown="1"> +{% highlight java %} +// get a StreamTableEnvironment, works for BatchTableEnvironment equivalently +StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env); + +// register Orders table +... + +// register SinkResult table +... + +// compute revenue for all customers from France and emit to SinkResult +tableEnv.sqlUpdate( + "INSERT INTO SinkResult" + --- End diff -- add whitespace to end of String
---