gobblin.util

Class WritableShimSerialization

java.lang.Object

gobblin.util.WritableShimSerialization

All Implemented Interfaces:

Serialization<WritableShim>

public class WritableShimSerialization
extends Object
implements Serialization<WritableShim>

A serializer that understands how to write objects that implement WritableShim out to a Hadoop stream. This class must be present in the io.serializations key of a Hadoop config for the Hadoop runtime to find and instantiate it.

Constructor Summary

Constructors

Constructor and Description
WritableShimSerialization()

Method Summary

Modifier and Type	Method and Description
boolean	accept(Class<?> c)
static void	addToHadoopConfiguration(Configuration conf) Helper method to add this serializer to an existing Hadoop config.
Deserializer<WritableShim>	getDeserializer(Class<WritableShim> c)
Serializer<WritableShim>	getSerializer(Class<WritableShim> c)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WritableShimSerialization

public WritableShimSerialization()

Method Detail

addToHadoopConfiguration

public static void addToHadoopConfiguration(Configuration conf)

Helper method to add this serializer to an existing Hadoop config.

accept

public boolean accept(Class<?> c)

Specified by:

accept in interface Serialization<WritableShim>

getSerializer

public Serializer<WritableShim> getSerializer(Class<WritableShim> c)

Specified by:

getSerializer in interface Serialization<WritableShim>

getDeserializer

public Deserializer<WritableShim> getDeserializer(Class<WritableShim> c)

Specified by:

getDeserializer in interface Serialization<WritableShim>