com.cloudera.crunch.type
Class PGroupedTableType.PairIterableMapFn<K,V>
java.lang.Object
com.cloudera.crunch.DoFn<S,T>
com.cloudera.crunch.MapFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>>
com.cloudera.crunch.type.PGroupedTableType.PairIterableMapFn<K,V>
- All Implemented Interfaces:
- Serializable
- Enclosing class:
- PGroupedTableType<K,V>
public static class PGroupedTableType.PairIterableMapFn<K,V>
- extends MapFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>>
- See Also:
- Serialized Form
Methods inherited from class com.cloudera.crunch.DoFn |
cleanup, configure, getConfiguration, getCounter, getCounter, getStatus, getTaskAttemptID, progress, setConfigurationForTest, setContext, setStatus |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PGroupedTableType.PairIterableMapFn
public PGroupedTableType.PairIterableMapFn(MapFn<Object,K> keys,
MapFn<Object,V> values)
initialize
public void initialize()
- Description copied from class:
DoFn
- Called during the setup of the MapReduce job this
DoFn
is associated with. Subclasses may override this method to
do appropriate initialization.
- Overrides:
initialize
in class DoFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>>
map
public Pair<K,Iterable<V>> map(Pair<Object,Iterable<Object>> input)
- Description copied from class:
MapFn
- Maps the given input into an instance of the output type.
- Specified by:
map
in class MapFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>>
Copyright © 2012. All Rights Reserved.