DataStream<Sensor> processStream = inputDataStream.filter(new TransientFallFilter());
DataStream<Event> outputStream = processStream.keyBy("k", "s").timeWindow(Time.minutes(2)).apply(new TransientRiseEventSelect());
是否有可能或 API 可以将动态时间值传递给 timeWindow(t) 函数？我有一个时间框架根据 key 变化的要求。
最佳答案
不，DataStream API 的默认时间窗口不支持此功能。
但是，应该可以使用自定义 WindowAssigner 和 Trigger 实现此类行为。 WindowAssigner 将记录分配给窗口，Trigger 决定何时计算窗口。
参见 docs了解详情。
关于api - 如何将动态值传递给 flink 中的 timeWindow(<dynamic_Time>)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45232804/