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

Package org.apache.crunch.impl.spark.fn

Class Summary

CombineMapsideFunction<K,V>
CrunchIterable<S,T>
FlatMapDoFn<S,T>
FlatMapPairDoFn<K,V,T>
InputConverterFunction<K,V,S>
MapFunction
MapOutputFunction<K,V>
OutputConverterFunction<K,V,S>
PairFlatMapDoFn<T,K,V>
PairFlatMapPairDoFn<K,V,K2,V2>
PairMapFunction<K,V,S>
PairMapIterableFunction<K,V,S,T>
PartitionedMapOutputFunction<K,V>
ReduceGroupingFunction
ReduceInputFunction<K,V>