1

私はflink sql apiを使用しており、次のようなSQLを持っています

Table result2 = tableEnv.sqlQuery(
    "SELECT user, SUM(amount) " +
    "FROM Orders " +
    "GROUP BY TUMBLE(proctime, INTERVAL '1' DAY), user"
);

「allowedLatenness」を有効にして、遅延データを副出力として取得できますか

4

1 に答える 1