| 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> | |
| MapKeysFn<K1,K2,V> | |
| MapValuesFn<K,V1,V2> | |
| PairMapFn<K,V,S,T> |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.