This project has retired. For details please refer to its Attic page.
AvroPairConverter (Apache Crunch 0.3.0-incubating API)

org.apache.crunch.types.avro
Class AvroPairConverter<K,V>

java.lang.Object
  extended by 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

Constructor Summary
AvroPairConverter()
           
 
Method Summary
 Pair<K,V> convertInput(org.apache.avro.mapred.AvroKey<K> key, org.apache.avro.mapred.AvroValue<V> value)
           
 Pair<K,Iterable<V>> convertIterableInput(org.apache.avro.mapred.AvroKey<K> key, Iterable<org.apache.avro.mapred.AvroValue<V>> iter)
           
 Class<org.apache.avro.mapred.AvroKey<K>> getKeyClass()
           
 Class<org.apache.avro.mapred.AvroValue<V>> getValueClass()
           
 org.apache.avro.mapred.AvroKey<K> outputKey(Pair<K,V> value)
           
 org.apache.avro.mapred.AvroValue<V> outputValue(Pair<K,V> value)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AvroPairConverter

public AvroPairConverter()
Method Detail

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.