[FLINK-10487] fix invalid Flink SQL example

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0, 1.6.1, 1.7.0
• Fix Version/s: 1.5.5, 1.6.2, 1.7.0
• Component/s: Documentation, Table SQL / API
• Labels: pull-request-available
• Assignee: Bowen Li
• Reporter: Bowen Li
• Created: 03/Oct/18 21:17
• Updated: 08/Oct/18 11:55
• Resolved: 08/Oct/18 11:55

Description

On https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html , the example is :

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%'");
...

But there's no API of toTable() in StreamTableEnvironment

cc fhueske

Issue Links

• links to: GitHub Pull Request #6790