0
私はFLINKのSQLウィンドウAPIを使用してみました: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table_api.html#group-windowsFLINKのSQLウィンドウのAPI
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");
はエラーを示しています。
No match found for function signature rowtime()
私FLINK-SQL-ウィンドウAPIについてのより詳細な例を教えてくださいrowtime.Thxで。