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

Flink如何自定义窗口分配器（WindowAssigner）？

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

Flink面试题 Flink

发布于：7小时前 IP属地：

1 个回答

ε星空下的誓言з永不忘

以下是具体额示例：
1、定义窗口类型

public class DynamicWindow extends TimeWindow {
    public DynamicWindow(long start, long end) {
        super(start, end);
    }
}

2、实现WindowAssigner

#代码详见
https://www.80wz.com/zb_users/upload/2025/05/20250516154919174738175912730.txt

3、在作业中使用

#代码详见
https://www.80wz.com/zb_users/upload/2025/05/20250516155003174738180381397.txt

发布于：7小时前 IP属地：

我来回答