开发者社区> 问答> 正文

FlinkSQL处理流计算,我想要统计一天的总和,并且10分钟输出一次。用Dat #Flink

FlinkSQL处理流计算,我想要统计一天的总和,并且10分钟输出一次。用DataStream API有trigger,请问SQL是怎么实现呢。大佬们提点一下?#Flink

展开
收起
黄一刀 2020-05-28 16:08:32 4805 0
1 条回答
写回答
取消 提交回答
  • bsTableEnv.getConfig().getConfiguration().setBoolean("table.exec.emit.early-fire.enabled", true); bsTableEnv.getConfig().getConfiguration().setString("table.exec.emit.early-fire.delay", "1000 ms");

    2020-05-28 17:33:33
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载