api - 如何在flink中将动态值传递给timeWindow(<dynamic_Time>)

DataStream<Sensor> processStream = inputDataStream.filter(new TransientFallFilter());

DataStream<Event> outputStream = processStream.keyBy("k", "s").timeWindow(Time.minutes(2)).apply(new TransientRiseEventSelect());

是否有可能将动态时间值传递给timeWindow（t）函数的API？我有一个时间范围根据密钥而变化的要求。

最佳答案

否，DataStream API的默认时间窗口不支持此功能。
但是，应该可以使用自定义WindowAssigner和Trigger来实现这种行为。 WindowAssigner将记录分配给窗口，而Trigger决定何时计算窗口。

有关详细信息，请参见docs。

关于api - 如何在flink中将动态值传递给timeWindow(<dynamic_Time>)，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/45232804/