如何在Apache Flink中实现每月的窗口

Question

flink只有相同长度的窗口吗？我如何使用可变大小的窗口在Flink流中每月工作？

Answer 1

您需要的大部分内容已经存在；缺少的是一个窗口分配程序，该窗口分配器知道如何构造适当（和变量）持续时间的窗口。假设您想在事件时间内操作，则可以基于TumblingEventTimeWindows，并修改AdgetWindows方法做正确的事。