cascading.tuple.hadoop.util
Class HasherPartitioner

java.lang.Object
  cascading.tuple.util.TupleHasher
      cascading.tuple.hadoop.util.HasherPartitioner

All Implemented Interfaces:

Serializable, JobConfigurable

Direct Known Subclasses:

CoGroupingPartitioner, GroupingPartitioner, GroupingSortingPartitioner

public class HasherPartitioner
extends TupleHasher
implements JobConfigurable

Super class of all Hadoop partitioners.

As of Cascading 2.7 the hashing used to calculate partitions has been changed to use Murmur3. Users that rely on the old behaviour should set HASHER_PARTITIONER_USE_LEGACY_HASH to true.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class cascading.tuple.util.TupleHasher

TupleHasher.HashFunction

Field Summary

static String

HASHER_PARTITIONER_USE_LEGACY_HASH

Fields inherited from class cascading.tuple.util.TupleHasher

hashFunction

Constructor Summary

HasherPartitioner()

Method Summary

void	configure(JobConf jobConf)

Methods inherited from class cascading.tuple.util.TupleHasher

getHashFunction, hashCode, initialize, isNull, merge, wrapTuple

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HASHER_PARTITIONER_USE_LEGACY_HASH

public static final String HASHER_PARTITIONER_USE_LEGACY_HASH

See Also:

Constant Field Values

Constructor Detail

HasherPartitioner

public HasherPartitioner()

Method Detail

configure

public void configure(JobConf jobConf)

Specified by:

configure in interface JobConfigurable