|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.conf.Configured cascading.tuple.hadoop.TupleSerialization
public class TupleSerialization
Class TupleSerialization is an implementation of Hadoop's Serialization
interface.
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 |
addSerialization(Map<Object,Object> properties,
String className)
Adds the given className as a Hadoop IO serialization class. |
static void |
addSerializationToken(Map<Object,Object> properties,
int token,
String className)
Adds the given token and className pair as a serialization token property. |
Class |
getClass(String className)
|
Comparator |
getComparator(Class type)
|
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 org.apache.hadoop.conf.Configured |
---|
setConf |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TupleSerialization()
public TupleSerialization(Configuration conf)
conf
- of type ConfigurationMethod Detail |
---|
public static void addSerializationToken(Map<Object,Object> properties, int token, String className)
properties
- of type Maptoken
- of type intclassName
- of type Stringpublic static String getSerializationTokens(Map<Object,Object> properties)
properties
- of type Map
public static void addSerialization(Map<Object,Object> properties, String className)
properties
- of type MapclassName
- of type Stringpublic static void setSerializations(JobConf jobConf)
jobConf
- of type JobConfpublic Configuration getConf()
getConf
in interface Configurable
getConf
in class Configured
public Comparator getComparator(Class type)
public SerializationElementReader getElementReader()
public SerializationElementWriter getElementWriter()
public boolean accept(Class c)
Serialization.accept(Class)
.
accept
in interface Serialization
c
- of type Class
public Deserializer getDeserializer(Class c)
Serialization.getDeserializer(Class)
.
getDeserializer
in interface Serialization
c
- of type Class
public Serializer getSerializer(Class c)
Serialization.getSerializer(Class)
.
getSerializer
in interface Serialization
c
- of type Class
public Class getClass(String className)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |