This project has retired. For details please refer to its Attic page.
Converter (Apache Crunch 0.4.0-incubating API)

org.apache.crunch.types
Interface Converter<K,V,S,T>

All Superinterfaces:
Serializable
All Known Implementing Classes:
AvroKeyConverter, AvroPairConverter, WritablePairConverter

public interface Converter<K,V,S,T>
extends Serializable

Converts the input key/value from a MapReduce task into the input to a DoFn, or takes the output of a DoFn and write it to the output key/values.


Method Summary
 S convertInput(K key, V value)
           
 T convertIterableInput(K key, Iterable<V> value)
           
 Class<K> getKeyClass()
           
 Class<V> getValueClass()
           
 K outputKey(S value)
           
 V outputValue(S value)
           
 

Method Detail

convertInput

S convertInput(K key,
               V value)

convertIterableInput

T convertIterableInput(K key,
                       Iterable<V> value)

outputKey

K outputKey(S value)

outputValue

V outputValue(S value)

getKeyClass

Class<K> getKeyClass()

getValueClass

Class<V> getValueClass()


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.