全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

如何使用Flink实现窗口操作？

提问者：帅平问题分类：面试刷题

如何使用Flink实现窗口操作？

Flink面试题 Flink

发布于：28分钟前 IP属地：

2 个回答

我是蓝天

大致分为以下几个步骤
1、设置时间语义

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 使用事件时间（需分配时间戳和生成 Watermark）
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

2、分配时间戳和watermark

DataStream<Event> dataStream = env.addSource(kafkaSource).assignTimestampsAndWatermarks(
        WatermarkStrategy.<Event>forBoundedOutOfOrderness(Duration.ofSeconds(5)).withTimestampAssigner((event, timestamp) -> event.getTimestamp()));

3、按键区分

KeyedStream<Event, String> keyedStream = dataStream.keyBy(event -> event.getUserId());

4、定义窗口分配器

// 滚动事件时间窗口（5秒）
WindowedStream<Event, String, TimeWindow> windowedStream = keyedStream.window(TumblingEventTimeWindows.of(Time.seconds(5)));

发布于：24分钟前 IP属地：

忘南忘北不忘你

5、应用窗口函数

// 使用 reduce 函数（输入和输出类型相同）
SingleOutputStreamOperator<Event> result = windowedStream.reduce((e1, e2) -> new Event(e1.getUserId(), e1.getValue() + e2.getValue()));
// 使用 aggregate 函数（更灵活，需自定义 AggregateFunction）
SingleOutputStreamOperator<Double> avgResult = windowedStream.aggregate(new AverageAggregateFunction());

6、输出结果

result.print();
env.execute("Window Operation Example");

发布于：23分钟前 IP属地：

我来回答