[ https://issues.apache.org/jira/browse/FLINK-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-10487: ----------------------------------- Labels: pull-request-available (was: ) > fix invalid Flink SQL example > ----------------------------- > > Key: FLINK-10487 > URL: https://issues.apache.org/jira/browse/FLINK-10487 > Project: Flink > Issue Type: Bug > Components: Documentation, Table API & SQL > Affects Versions: 1.6.0, 1.6.1, 1.7.0 > Reporter: Bowen Li > Assignee: Bowen Li > Priority: Major > Labels: pull-request-available > Fix For: 1.7.0 > > > On https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html > , the example is : > {code:java} > StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env); > // ingest a DataStream from an external source > 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.sqlQuery( > "SELECT SUM(amount) FROM " + table + " WHERE product LIKE '%Rubber%'"); > ... > {code} > But there's no API of {{toTable()}} in StreamTableEnvironment > cc [~fhueske] -- This message was sent by Atlassian JIRA (v7.6.3#76005)