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
  extended by 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

Constructor Summary
AvroKeyConverter()
           
 
Method Summary
 K convertInput(org.apache.avro.mapred.AvroWrapper<K> key, org.apache.hadoop.io.NullWritable value)
           
 Iterable<K> convertIterableInput(org.apache.avro.mapred.AvroWrapper<K> key, Iterable<org.apache.hadoop.io.NullWritable> value)
           
 Class<org.apache.avro.mapred.AvroWrapper<K>> getKeyClass()
           
 Class<org.apache.hadoop.io.NullWritable> getValueClass()
           
 org.apache.avro.mapred.AvroWrapper<K> outputKey(K value)
           
 org.apache.hadoop.io.NullWritable outputValue(K value)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AvroKeyConverter

public AvroKeyConverter()
Method Detail

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.