可以使用输入流中的时间戳在Flink中创建翻滚窗口。如果是,那么如何?

问题描述 投票:0回答:1

我一直在尝试在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是否支持这种功能?如果是,那么示例代码/过程将有很大帮助。

预先感谢。

apache-kafka apache-flink flink-streaming
1个回答
0
投票

您的用例非常普遍。您想添加一个timestamp extractor,以使Flink知道事件的时间戳。如果使用event time processing,则翻滚窗口的行为将符合您的预期。

© www.soinside.com 2019 - 2024. All rights reserved.