flink什么时候使用timewindowAll
flink when to use timewindowAll
我有一个使用以下形状的数据的管道：
case class Foo(source: String, destination: String){def key=source+destination} 我想删除在同一小时到达的所有 source+destination 重复项，然后我想计算在同一小时到达目的地的所有呼叫。我创建了一个带有 src ~> timewindow1(1 hour, keyBy:key) ~> timewindow2(1 hour, keyBy:destination) ~> ... 的管道，我应该在 timewindow2 中使用 timewindowAll 吗？
您应该只在不想使用键分区窗口的情况下使用 timeWindowAll。由于您是按目的地键入的，因此您应该使用 timeWindow，而不是 timeWindowAll。
我有一个使用以下形状的数据的管道：
case class Foo(source: String, destination: String){def key=source+destination} 我想删除在同一小时到达的所有 source+destination 重复项，然后我想计算在同一小时到达目的地的所有呼叫。我创建了一个带有 src ~> timewindow1(1 hour, keyBy:key) ~> timewindow2(1 hour, keyBy:destination) ~> ... 的管道，我应该在 timewindow2 中使用 timewindowAll 吗？
您应该只在不想使用键分区窗口的情况下使用 timeWindowAll。由于您是按目的地键入的，因此您应该使用 timeWindow，而不是 timeWindowAll。