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:10 GMT
Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3829#discussion_r139470942
  
    --- Diff: docs/dev/table/sql.md ---
    @@ -49,15 +49,29 @@ DataStream<Tuple3<Long, String, Integer>> ds = env.addSource(...);
     
     // SQL query with an inlined (unregistered) table
     Table table = tableEnv.toTable(ds, "user, product, amount");
    -Table result = tableEnv.sql(
    +Table result = tableEnv.sqlQuery(
       "SELECT SUM(amount) FROM " + table + " WHERE product LIKE '%Rubber%'");
     
     // SQL query with a registered table
     // register the DataStream as table "Orders"
     tableEnv.registerDataStream("Orders", ds, "user, product, amount");
     // run a SQL query on the Table and retrieve the result as a new Table
    -Table result2 = tableEnv.sql(
    +Table result2 = tableEnv.sqlQuery(
       "SELECT product, amount FROM Orders WHERE product LIKE '%Rubber%'");
    +
    +// SQL update with a registered table
    +// register the DataStream as table "Orders"
    +tableEnv.registerDataStream("Orders", ds, "user, product, amount");
    --- End diff --
    
    I think we can reuse the previously registered Orders table.


---

Mime
View raw message