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

Class IntactPartitioner

java.lang.Object

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

All Implemented Interfaces:

Partitioner

public final class IntactPartitioner
extends Object
implements Partitioner

An implementation of Partitioner which makes an output data from a source task to a single Partition.

Constructor Summary

Constructors

Constructor and Description
IntactPartitioner()

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

IntactPartitioner

public IntactPartitioner()

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.