| 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 © 2017 The Apache Software Foundation. All rights reserved.