org.apache.crunch.types

Interface Converter<K,V,S,T>

All Superinterfaces:

Serializable

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

Methods

Modifier and Type	Method and Description
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()