项目应用问题求老师或者高手解答

来源：3-7 指定key之字段表达式

qq_DESIGNER_7

2019-04-18

pk老师你好，之前没有用过flink，购买了您的flink课程，感觉讲的很不错。但我现在有个问题不知道怎么用flink解决好，不知道是否能给出一个思路? 我基于项目上的kafka source作为数据源需求是要每隔10s计算每小时（数据中有时间字段）各个app版本的活跃用户数（连续count，既下一个10s的count结果要加上这次的10s），不知道是该使用table api还是窗口，具体怎么实现能否给个思路。

写回答

1回答