Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
org.apache.crunch.impl.dist.collect | |
org.apache.crunch.impl.spark | |
org.apache.crunch.impl.spark.fn | |
org.apache.crunch.lib |
Joining, sorting, aggregating, and other commonly used functionality.
|
org.apache.crunch.types |
Common functionality for business object serialization.
|
Modifier and Type | Method and Description |
---|---|
PGroupedTableType<K,V> |
PGroupedTable.getGroupedTableType()
Return the
PGroupedTableType containing serialization information for
this PGroupedTable . |
Modifier and Type | Method and Description |
---|---|
PGroupedTableType<K,V> |
BaseGroupedTable.getGroupedTableType() |
Constructor and Description |
---|
SparkComparator(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt) |
Constructor and Description |
---|
PartitionedMapOutputFunction(SerDe<K> keySerde,
SerDe<V> valueSerde,
PGroupedTableType<K,V> ptype,
int numPartitions,
GroupingOptions options,
SparkRuntimeContext runtimeContext) |
ReduceGroupingFunction(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt) |
Modifier and Type | Method and Description |
---|---|
static <K,V> Pair<K,Iterable<V>> |
PTables.getGroupedDetachedValue(PGroupedTableType<K,V> groupedTableType,
Pair<K,Iterable<V>> value)
Created a detached value for a
PGroupedTable value. |
Modifier and Type | Method and Description |
---|---|
PGroupedTableType<K,V> |
PTableType.getGroupedTableType()
Returns the grouped table version of this type.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.