代码之家  ›  专栏  ›  技术社区  ›  Richard Deurwaarder

ApacheFlink-数据集API-如何将n个结果组合在一起

  •  1
  • Richard Deurwaarder  · 技术社区  · 7 年前

    如果我们使用数据流API,我们就可以使用类似于滚动窗口的东西。( https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators/windows.html#tumbling-windows

    但这在进行批处理时不可用。

    1 回复  |  直到 7 年前
        1
  •  3
  •   Fabian Hueske    7 年前

    如果这些记录可以任意组合在一起,我就不会使用 groupBy reduce ,或 groupReduce DataSet .

    MapPartitionFunction MapPartition