public final class HashPartitioner extends Object implements Partitioner
Partitionerwhich hashes output data from a source task according to the key of elements. The data will be hashed by their key, and applied "modulo" operation by the number of destination tasks.
|Constructor and Description|
|Modifier and Type||Method and Description|
Divides the output data from a task into multiple blocks.
public List<Partition> partition(Iterable elements, int dstParallelism, KeyExtractor keyExtractor)
Copyright © 2018. All rights reserved.