public class GroupingSortingPartitioner extends HasherPartitioner implements Partitioner<cascading.tuple.io.TuplePair,cascading.tuple.Tuple>
Partitioner
.HASHER_PARTITIONER_USE_LEGACY_HASH
Constructor and Description |
---|
GroupingSortingPartitioner() |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf job) |
int |
getPartition(cascading.tuple.io.TuplePair key,
cascading.tuple.Tuple value,
int numReduceTasks) |
getConf, setConf
public GroupingSortingPartitioner()
public int getPartition(cascading.tuple.io.TuplePair key, cascading.tuple.Tuple value, int numReduceTasks)
getPartition
in interface Partitioner<cascading.tuple.io.TuplePair,cascading.tuple.Tuple>
public void configure(JobConf job)
configure
in interface JobConfigurable
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.