文件名称：flink-java-interview:Flink面试练习
文件大小：9KB
文件格式：ZIP
更新时间：2024-06-01 07:51:53
streaming interview flink Java
Flink面试 前任。 1个 该练习的目的是： 在WalkMeEventSourceFunction中生成随机WalkMeEvents。 在10秒钟的（Tumbling）窗口中编写汇总事件的代码。 每10秒打印一次最近10秒内每个用户的事件总数。 脚步 实现WalkMeEventSourceFunction类 实现StreamingJob主要功能 运行StreamingJob类： mvn clean package mvn exec:java -Dexec.mainClass=com.walkme.data.streaming.ex1.StreamingJob 预期产量 21:26:22,145 INFO com.walkme.data.streaming.ex1.AggregationsSinkFunction - User: [user-2] Sent: [8]
【文件预览】：
flink-java-interview-master
----src()
--------main()
----README.md(2KB)
----pom.xml(11KB)
----.gitignore(19B)