edu.snu.coral.runtime.executor.data.partitioner

Class HashPartitioner

java.lang.Object

edu.snu.coral.runtime.executor.data.partitioner.HashPartitioner

All Implemented Interfaces:

Partitioner

public final class HashPartitioner
extends Object
implements Partitioner

An implementation of Partitioner which 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 Summary

Constructors

Constructor and Description
HashPartitioner()

Method Summary

Modifier and Type	Method and Description
List<Partition>	partition(Iterable elements, int dstParallelism, KeyExtractor keyExtractor) Divides the output data from a task into multiple blocks.

Methods inherited from class java.lang.Object

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

Constructor Detail

HashPartitioner

public HashPartitioner()

Method Detail

partition

public List<Partition> partition(Iterable elements,
                                 int dstParallelism,
                                 KeyExtractor keyExtractor)

Description copied from interface: Partitioner

Divides the output data from a task into multiple blocks.

Specified by:

partition in interface Partitioner

Parameters:

elements - the output data from a source task.

dstParallelism - the number of destination tasks.

keyExtractor - extracts keys from elements.

Returns:

the list of partitioned blocks.