flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhueske <...@git.apache.org>
Subject [GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...
Date Mon, 18 Sep 2017 20:52:09 GMT
Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3829#discussion_r139468211
  
    --- 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
    --- End diff --
    
    change to `// register RevenueFrance table as TableSink`?


---

Mime
View raw message