com.cloudera.crunch.type.avro
Class AvroKeyConverter<K>
java.lang.Object
com.cloudera.crunch.type.avro.AvroKeyConverter<K>
- All Implemented Interfaces:
- Converter<org.apache.avro.mapred.AvroWrapper<K>,org.apache.hadoop.io.NullWritable,K,Iterable<K>>, Serializable
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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. All Rights Reserved.