Hi, The document you are looking at is pretty old, you can check the newest version here: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/batch/dataset_transformations.html
Regarding to your question, you can use combineGroup Best, Kurt On Mon, Oct 23, 2017 at 5:22 AM, Le Xu <sharonx...@gmail.com> wrote: > Hello! > > I'm new to Flink and I'm wondering if there is a explicit local combiner > to each mapper so I can use to perform a local reduce on each mapper? I > looked up on https://ci.apache.org/projects/flink/flink-docs- > release-0.8/dataset_transformations.html but couldn't find anything that > matches. > > > Thanks! > > Le >
