Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r139471468 --- 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" + + "SELECT cID, cName, SUM(revenue) AS revSum " + + "FROM Orders " + + "WHERE cCountry = 'FRANCE' " + + "GROUP BY cID, cName" + ); + +// execute query +{% endhighlight %} +</div> + +<div data-lang="scala" markdown="1"> +{% highlight scala %} +// get a TableEnvironment +val tableEnv = TableEnvironment.getTableEnvironment(env) + +// register Orders table +... + +// register SinkResult table --- End diff -- same as above
---