public interface Partitioner
Partitions, according to the number of destination tasks, the key of each element, etc.
List<Partition> partition(Iterable elements, int dstParallelism, KeyExtractor keyExtractor)
elements- the output data from a source task.
dstParallelism- the number of destination tasks.
keyExtractor- extracts keys from elements.
Copyright © 2018. All rights reserved.