我一直在尝试在Flink-Kafka使用者上使用翻转窗口。 Flink将以Json格式从KafkaStream接收输入:
>{"eventGroup":"1121212" , "eventTime":"2020-01-02T13:43:43"}
>{"eventGroup":"1121212" , "eventTime":"2020-01-02T13:43:44"}
>{"eventGroup":"1121213" , "eventTime":"2020-01-02T13:43:48"}
我想针对eventTime介于2020-01-02T13:40:00到2020-01-02T13:44:59之间的所有timeTime值按eventGroup对该流进行分组。flink Tumbling Windows是否支持这种功能?如果是,那么示例代码/过程将有很大帮助。
预先感谢。
您的用例非常普遍。您想添加一个timestamp extractor,以使Flink知道事件的时间戳。如果使用event time processing,则翻滚窗口的行为将符合您的预期。