flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Le Xu <sharonx...@gmail.com>
Subject Local combiner on each mapper in Flink
Date Sun, 22 Oct 2017 21:22:00 GMT
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

Mime
View raw message