Package | Description |
---|---|
edu.snu.coral.runtime.executor.data | |
edu.snu.coral.runtime.executor.data.partitioner |
Modifier and Type | Class and Description |
---|---|
class |
NonSerializedPartition<K>
A collection of data elements.
|
class |
SerializedPartition<K>
A collection of data elements.
|
Modifier and Type | Method and Description |
---|---|
Optional<List<Long>> |
BlockManagerWorker.putPartitions(String blockId,
Iterable<Partition> partitions,
DataStoreProperty.Value blockStore)
Store an iterable of data partitions to a block in the target
BlockStore . |
Modifier and Type | Method and Description |
---|---|
List<Partition> |
HashPartitioner.partition(Iterable elements,
int dstParallelism,
KeyExtractor keyExtractor) |
List<Partition> |
Partitioner.partition(Iterable elements,
int dstParallelism,
KeyExtractor keyExtractor)
Divides the output data from a task into multiple blocks.
|
List<Partition> |
IntactPartitioner.partition(Iterable elements,
int dstParallelism,
KeyExtractor keyExtractor) |
List<Partition> |
DataSkewHashPartitioner.partition(Iterable elements,
int dstParallelism,
KeyExtractor keyExtractor) |
Copyright © 2018. All rights reserved.