| 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.