Class | Description |
---|---|
Aggregators |
A collection of pre-defined
Aggregator s. |
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> | |
MapKeysFn<K1,K2,V> | |
MapValuesFn<K,V1,V2> | |
PairMapFn<K,V,S,T> |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.