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