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