This project has retired. For details please refer to its Attic page.

Uses of Interface
org.apache.crunch.impl.spark.serde.SerDe

Packages that use SerDe

org.apache.crunch.impl.spark.fn
org.apache.crunch.impl.spark.serde

Uses of SerDe in org.apache.crunch.impl.spark.fn

Constructors in org.apache.crunch.impl.spark.fn with parameters of type SerDe

MapOutputFunction(SerDe keySerde, SerDe valueSerde)

MapOutputFunction(SerDe keySerde, SerDe valueSerde)

PartitionedMapOutputFunction(SerDe<K> keySerde, SerDe<V> valueSerde, PGroupedTableType<K,V> ptype, Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass, int numPartitions, SparkRuntimeContext runtimeContext)

PartitionedMapOutputFunction(SerDe<K> keySerde, SerDe<V> valueSerde, PGroupedTableType<K,V> ptype, Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass, int numPartitions, SparkRuntimeContext runtimeContext)

ReduceInputFunction(SerDe<K> keySerDe, SerDe<V> valueSerDe)

ReduceInputFunction(SerDe<K> keySerDe, SerDe<V> valueSerDe)

Uses of SerDe in org.apache.crunch.impl.spark.serde

Classes in org.apache.crunch.impl.spark.serde that implement SerDe

class	AvroSerDe<T>
class	WritableSerDe