Package | Description |
---|---|
edu.snu.coral.common.ir.edge.executionproperty | |
edu.snu.coral.compiler.frontend.spark | |
edu.snu.coral.runtime.executor.data.partitioner |
Modifier and Type | Method and Description |
---|---|
static KeyExtractorProperty |
KeyExtractorProperty.of(KeyExtractor value)
Static method exposing the constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
SparkKeyExtractor
Extracts the key from a KV element.
|
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.