This project has retired. For details please refer to its
Attic page .
PGroupedTableType.PairIterableMapFn (Apache Crunch 0.4.0-incubating API)
org.apache.crunch.types
Class PGroupedTableType.PairIterableMapFn<K,V>
java.lang.Object
org.apache.crunch.DoFn <S,T>
org.apache.crunch.MapFn <Pair <Object ,Iterable <Object >>,Pair <K,Iterable <V>>>
org.apache.crunch.types.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
PGroupedTableType.PairIterableMapFn
public PGroupedTableType.PairIterableMapFn (MapFn <Object ,K > keys,
MapFn <Object ,V > values)
configure
public void configure (org.apache.hadoop.conf.Configuration conf)
Description copied from class: DoFn
Configure this DoFn. Subclasses may override this method to modify the
configuration of the Job that this DoFn instance belongs to.
Called during the job planning phase by the crunch-client.
Overrides: configure
in class DoFn <Pair <Object ,Iterable <Object >>,Pair <K ,Iterable <V >>>
Parameters: conf
- The Configuration instance for the Job.
initialize
public void initialize ()
Description copied from class: DoFn
Initialize this DoFn. This initialization will happen before the actual
DoFn.process(Object, Emitter)
is triggered. Subclasses may override
this method to do appropriate initialization.
Called during the setup of the job instance this DoFn
is associated
with.
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 The Apache Software Foundation . All Rights Reserved.