2017-06-08 13 views
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で。

答えて

1

現在のところ、ドキュメントは同期がとれていませんが、コミュニティは別のブランチで作業しています。 Flink 1.3では、将来的により明示的に時間にアクセスし、表現し、作業するために、いわゆる「時間属性」が導入されています。

さらに詳しい情報はcurrent documentation draftにあります。テーブルプログラムで時間属性を使用する方法の例は、hereです。

関連する問題