cascading.tuple.hadoop
Class TupleSerialization

java.lang.Object
  Configured
      cascading.tuple.hadoop.TupleSerialization

public class TupleSerialization
extends Configured

Class TupleSerialization is an implementation of Hadoop's Serialization interface.

Typically developers will not use this implementation directly as it is automatically added to any relevant MapReduce jobs via the JobConf.

By default, all primitive types are natively handled, and BytesWritable has a pre-configured serialization token since byte arrays are not handled natively by Tuple.

Constructor Summary

TupleSerialization()
Constructor TupleSerialization creates a new TupleSerialization instance.

TupleSerialization(Configuration conf)
Constructor TupleSerialization creates a new TupleSerialization instance.

Method Summary

boolean	accept(Class c) Method accept implements Serialization#accept(Class).
static void	addSerializationToken(Map<Object,Object> properties, int token, String className) Adds the given token and className pair as a serialization token property.
Configuration	getConf()
Deserializer	getDeserializer(Class c) Method getDeserializer implements Serialization#getDeserializer(Class).
SerializationElementReader	getElementReader() Method getElementReader returns the elementReader of this TupleSerialization object.
SerializationElementWriter	getElementWriter() Method getElementWriter returns the elementWriter of this TupleSerialization object.
static String	getSerializationTokens(Map<Object,Object> properties) Returns the serialization tokens property.
Serializer	getSerializer(Class c) Method getSerializer implements Serialization#getSerializer(Class).
static void	setSerializations(JobConf jobConf) Adds this class as a Hadoop Serialization class.

Methods inherited from class java.lang.Object

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

Constructor Detail

TupleSerialization

public TupleSerialization()

Constructor TupleSerialization creates a new TupleSerialization instance.

TupleSerialization

public TupleSerialization(Configuration conf)

Constructor TupleSerialization creates a new TupleSerialization instance.

Parameters:

conf - of type Configuration

Method Detail

addSerializationToken

public static void addSerializationToken(Map<Object,Object> properties,
                                         int token,
                                         String className)

Adds the given token and className pair as a serialization token property. During object serialization and deserialization, the given token will be used instead of the className when an instance of the className is encountered.

Parameters:

properties - of type Map

token - of type int

className - of type String

getSerializationTokens

public static String getSerializationTokens(Map<Object,Object> properties)

Returns the serialization tokens property.

Parameters:

properties - of type Map

Returns:

returns a String

setSerializations

public static void setSerializations(JobConf jobConf)

Adds this class as a Hadoop Serialization class. This method is safe to call redundantly.

Parameters:

jobConf - of type JobConf

getConf

public Configuration getConf()

getElementReader

public SerializationElementReader getElementReader()

Method getElementReader returns the elementReader of this TupleSerialization object.

Returns:

the elementReader (type SerializationElementReader) of this TupleSerialization object.

getElementWriter

public SerializationElementWriter getElementWriter()

Method getElementWriter returns the elementWriter of this TupleSerialization object.

Returns:

the elementWriter (type SerializationElementWriter) of this TupleSerialization object.

accept

public boolean accept(Class c)

Method accept implements Serialization#accept(Class).

Parameters:

c - of type Class

Returns:

boolean

getDeserializer

public Deserializer getDeserializer(Class c)

Method getDeserializer implements Serialization#getDeserializer(Class).

Parameters:

c - of type Class

Returns:

Deserializer

getSerializer

public Serializer getSerializer(Class c)

Method getSerializer implements Serialization#getSerializer(Class).

Parameters:

c - of type Class

Returns:

Serializer