并行

demo

Flink 示意图

窗口模式图

窗口模式处理

Datastream<String>lines=env. addSource(
new FlinkKafkaConsumer<>(…)); Datastream<Event> events=lines. map((line)->parse(line)); DataStream<Statistics> stats=evepts
. keyBy("id")
. timeWindow(Time. seconds(10))
. apply(new MyWindowAggregationFunction()); stats. addsink(new Rollingsink(path));