This project has retired. For details please refer to its
Attic page.
AvroPairConverter (Apache Crunch 0.4.0-incubating API)
org.apache.crunch.types.avro
Class AvroPairConverter<K,V>
java.lang.Object
org.apache.crunch.types.avro.AvroPairConverter<K,V>
- All Implemented Interfaces:
- Serializable, Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
public class AvroPairConverter<K,V>
- extends Object
- implements Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
- See Also:
- Serialized Form
AvroPairConverter
public AvroPairConverter()
convertInput
public Pair<K,V> convertInput(org.apache.avro.mapred.AvroKey<K> key,
org.apache.avro.mapred.AvroValue<V> value)
- Specified by:
convertInput
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
convertIterableInput
public Pair<K,Iterable<V>> convertIterableInput(org.apache.avro.mapred.AvroKey<K> key,
Iterable<org.apache.avro.mapred.AvroValue<V>> iter)
- Specified by:
convertIterableInput
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
outputKey
public org.apache.avro.mapred.AvroKey<K> outputKey(Pair<K,V> value)
- Specified by:
outputKey
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
outputValue
public org.apache.avro.mapred.AvroValue<V> outputValue(Pair<K,V> value)
- Specified by:
outputValue
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
getKeyClass
public Class<org.apache.avro.mapred.AvroKey<K>> getKeyClass()
- Specified by:
getKeyClass
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
getValueClass
public Class<org.apache.avro.mapred.AvroValue<V>> getValueClass()
- Specified by:
getValueClass
in interface Converter<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>,Pair<K,V>,Pair<K,Iterable<V>>>
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.