@InterfaceAudience.Private public static class UnorderedKVOutput.CustomPartitioner extends Object implements Partitioner
| Constructor and Description |
|---|
UnorderedKVOutput.CustomPartitioner() |
public int getPartition(Object key, Object value, int numPartitions)
PartitionergetPartition in interface Partitionerkey - keyvalue - valuenumPartitions - number of partitionsCopyright © 2016 Apache Software Foundation. All rights reserved.