com.cloudera.crunch.type.writable
Class WritablePairConverter<K,V>
java.lang.Object
com.cloudera.crunch.type.writable.WritablePairConverter<K,V>
- All Implemented Interfaces:
- Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>, Serializable
public class WritablePairConverter<K,V>
- extends Object
- implements Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WritablePairConverter
public WritablePairConverter(Class<K> keyClass,
Class<V> valueClass)
convertInput
public Pair<K,V> convertInput(K key,
V value)
- Specified by:
convertInput
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
outputKey
public K outputKey(Pair<K,V> value)
- Specified by:
outputKey
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
outputValue
public V outputValue(Pair<K,V> value)
- Specified by:
outputValue
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
getKeyClass
public Class<K> getKeyClass()
- Specified by:
getKeyClass
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
getValueClass
public Class<V> getValueClass()
- Specified by:
getValueClass
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
convertIterableInput
public Pair<K,Iterable<V>> convertIterableInput(K key,
Iterable<V> value)
- Specified by:
convertIterableInput
in interface Converter<K,V,Pair<K,V>,Pair<K,Iterable<V>>>
Copyright © 2012. All Rights Reserved.