com.cloudera.crunch.fn
Class MapKeysFn<K1,K2,V>
java.lang.Object
com.cloudera.crunch.DoFn<Pair<K1,V>,Pair<K2,V>>
com.cloudera.crunch.fn.MapKeysFn<K1,K2,V>
- All Implemented Interfaces:
- Serializable
public abstract class MapKeysFn<K1,K2,V>
- extends DoFn<Pair<K1,V>,Pair<K2,V>>
- See Also:
- Serialized Form
Methods inherited from class com.cloudera.crunch.DoFn |
cleanup, configure, getConfiguration, getCounter, getCounter, getStatus, getTaskAttemptID, initialize, progress, scaleFactor, setConfigurationForTest, setContext, setStatus |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MapKeysFn
public MapKeysFn()
process
public void process(Pair<K1,V> input,
Emitter<Pair<K2,V>> emitter)
- Description copied from class:
DoFn
- Processes the records from a
PCollection
.
- Specified by:
process
in class DoFn<Pair<K1,V>,Pair<K2,V>>
- Parameters:
input
- The input recordemitter
- The emitter to send the output to
map
public abstract K2 map(K1 k1)
Copyright © 2012. All Rights Reserved.