flink sql窗口api答案

【问题标题】：flink sql window apiflink sql窗口api
【发布时间】：2017-06-08 04:36:31
【问题描述】：

我尝试使用 flink sql window api： https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table_api.html#group-windows

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);

// ingest a DataStream from an external source
DataStream<Tuple3<Long, String, Integer>> ds = env.addSource(...);
// register the DataStream as table "Orders"
tableEnv.registerDataStream("Orders", ds, "user, product, amount");

// compute SUM(amount) per day (in event-time)
Table result1 = tableEnv.sql(
  "SELECT user, " +
  "  TUMBLE_START(rowtime(), INTERVAL '1' DAY) as wStart,  " +
  "  SUM(amount) FROM Orders " + 
  "GROUP BY TUMBLE(rowtime(), INTERVAL '1' DAY), user");

显示错误：

未找到函数签名 rowtime() 的匹配项

请给我一个关于 flink-sql-window api 和 rowtime.Thx 的更详细示例。

【问题讨论】：

标签： apache-flink flink-streaming

【解决方案1】：

目前文档有点不同步，但社区正在一个单独的分支中处理它。 Flink 1.3 引入了所谓的“时间属性”，以便在未来更明确地访问、表达和处理时间。

您可以在current documentation draft 中找到更多信息。在表格程序中如何使用时间属性的一些例子可以在here找到。

【讨论】：