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

org.apache.crunch.types.avro
Class SafeAvroSerialization<T>

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.crunch.types.avro.SafeAvroSerialization<T>
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.serializer.Serialization<org.apache.avro.mapred.AvroWrapper<T>>

public class SafeAvroSerialization<T>
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.io.serializer.Serialization<org.apache.avro.mapred.AvroWrapper<T>>

The Serialization used by jobs configured with AvroJob.


Constructor Summary
SafeAvroSerialization()
           
 
Method Summary
 boolean accept(Class<?> c)
           
 org.apache.hadoop.io.serializer.Deserializer<org.apache.avro.mapred.AvroWrapper<T>> getDeserializer(Class<org.apache.avro.mapred.AvroWrapper<T>> c)
          Returns the specified map output deserializer.
 org.apache.hadoop.io.serializer.Serializer<org.apache.avro.mapred.AvroWrapper<T>> getSerializer(Class<org.apache.avro.mapred.AvroWrapper<T>> c)
          Returns the specified output serializer.
 
Methods inherited from class org.apache.hadoop.conf.Configured
getConf, setConf
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SafeAvroSerialization

public SafeAvroSerialization()
Method Detail

accept

public boolean accept(Class<?> c)
Specified by:
accept in interface org.apache.hadoop.io.serializer.Serialization<org.apache.avro.mapred.AvroWrapper<T>>

getDeserializer

public org.apache.hadoop.io.serializer.Deserializer<org.apache.avro.mapred.AvroWrapper<T>> getDeserializer(Class<org.apache.avro.mapred.AvroWrapper<T>> c)
Returns the specified map output deserializer. Defaults to the final output deserializer if no map output schema was specified.

Specified by:
getDeserializer in interface org.apache.hadoop.io.serializer.Serialization<org.apache.avro.mapred.AvroWrapper<T>>

getSerializer

public org.apache.hadoop.io.serializer.Serializer<org.apache.avro.mapred.AvroWrapper<T>> getSerializer(Class<org.apache.avro.mapred.AvroWrapper<T>> c)
Returns the specified output serializer.

Specified by:
getSerializer in interface org.apache.hadoop.io.serializer.Serialization<org.apache.avro.mapred.AvroWrapper<T>>


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.