org.apache.crunch.lib.sort
Class SortFns.AvroGenericFn<V extends Tuple>
java.lang.Object
org.apache.crunch.DoFn<S,T>
org.apache.crunch.MapFn<V,org.apache.avro.generic.GenericRecord>
org.apache.crunch.lib.sort.SortFns.AvroGenericFn<V>
- All Implemented Interfaces:
- Serializable
- Enclosing class:
- SortFns
public static class SortFns.AvroGenericFn<V extends Tuple>
- extends MapFn<V,org.apache.avro.generic.GenericRecord>
Pulls a composite set of keys from an Avro GenericRecord
instance.
- See Also:
- Serialized Form
Method Summary |
void |
initialize()
Initialize this DoFn. |
org.apache.avro.generic.GenericRecord |
map(V input)
Maps the given input into an instance of the output type. |
SortFns.AvroGenericFn
public SortFns.AvroGenericFn(int[] indices,
org.apache.avro.Schema schema)
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<V extends Tuple,org.apache.avro.generic.GenericRecord>
map
public org.apache.avro.generic.GenericRecord map(V input)
- Description copied from class:
MapFn
- Maps the given input into an instance of the output type.
- Specified by:
map
in class MapFn<V extends Tuple,org.apache.avro.generic.GenericRecord>
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.