Package | Description |
---|---|
org.apache.crunch.impl.spark.fn | |
org.apache.crunch.impl.spark.serde |
Constructor and Description |
---|
MapOutputFunction(SerDe keySerde,
SerDe valueSerde) |
MapOutputFunction(SerDe keySerde,
SerDe valueSerde) |
PartitionedMapOutputFunction(SerDe<K> keySerde,
SerDe<V> valueSerde,
PGroupedTableType<K,V> ptype,
int numPartitions,
GroupingOptions options,
SparkRuntimeContext runtimeContext) |
PartitionedMapOutputFunction(SerDe<K> keySerde,
SerDe<V> valueSerde,
PGroupedTableType<K,V> ptype,
int numPartitions,
GroupingOptions options,
SparkRuntimeContext runtimeContext) |
ReduceInputFunction(SerDe<K> keySerDe,
SerDe<V> valueSerDe) |
ReduceInputFunction(SerDe<K> keySerDe,
SerDe<V> valueSerDe) |
Modifier and Type | Class and Description |
---|---|
class |
AvroSerDe<T> |
class |
WritableSerDe |
Modifier and Type | Method and Description |
---|---|
static SerDe |
SerDeFactory.create(PType<?> ptype,
org.apache.hadoop.conf.Configuration conf) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.