Package org.apache.crunch.fn

Commonly used functions for manipulating collections.

See: Description

Class Summary

Class	Description
Aggregators	A collection of pre-defined Aggregators.
Aggregators.SimpleAggregator<T>	Base class for aggregators that do not require any initialization.
CompositeMapFn<R,S,T>
ExtractKeyFn<K,V>	Wrapper function for converting a MapFn into a key-value pair that is used to convert from a PCollection<V> to a PTable<K, V>.
FilterFns	A collection of pre-defined FilterFn implementations.
IdentityFn<T>
PairMapFn<K,V,S,T>
SDoubleFlatMapFunction<T>	A Crunch-compatible abstract base class for Spark's DoubleFlatMapFunction.
SDoubleFunction<T>	A Crunch-compatible abstract base class for Spark's DoubleFunction.
SFlatMapFunction<T,R>	A Crunch-compatible abstract base class for Spark's FlatMapFunction.
SFlatMapFunction2<K,V,R>	A Crunch-compatible abstract base class for Spark's FlatMapFunction2.
SFunction<T,R>	A Crunch-compatible abstract base class for Spark's Function.
SFunction2<K,V,R>	A Crunch-compatible abstract base class for Spark's Function2.
SFunctions	Utility methods for wrapping existing Spark Java API Functions for Crunch compatibility.
SPairFlatMapFunction<T,K,V>	A Crunch-compatible abstract base class for Spark's PairFlatMapFunction.
SPairFunction<T,K,V>	A Crunch-compatible abstract base class for Spark's PairFunction.
SwapFn<V1,V2>	Swap the elements of a Pair type.

Package org.apache.crunch.fn Description

Commonly used functions for manipulating collections.