我想计算两个非连续事件之间的时间差在Apache Flink中。一个事件由一个名称和一个时间戳组成。例如：E1（“A”，时间戳）-〉E2（“B”，时间戳）-〉E3（“C”，时间戳）在本例中，我想计算E3和E1之间的时间戳差异。关于如何在Flink中使用它，您有什么想法吗？
w6lpcovy1#
因为E1和E3有不同的键，你需要使用一个无键窗口（.windowAll()），参见this doc。因为你通常不能依赖于事件的原始顺序，在你的自定义ProcessWindowFunction中你必须按时间戳排序，以便能够可靠地计算增量。
.windowAll()
1条答案
按热度按时间w6lpcovy1#
因为E1和E3有不同的键，你需要使用一个无键窗口（
.windowAll()），参见this doc。因为你通常不能依赖于事件的原始顺序，在你的自定义ProcessWindowFunction中你必须按时间戳排序，以便能够可靠地计算增量。