|
|||||||||
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
.
To add or manipulate Hadoop serializations or Cascading serializations tokens, see
TupleSerializationProps
for a fluent property builder class.
By default this Serialization interface registers the class ByteWritable
as
token 127.
Nested Class Summary | |
---|---|
static class |
TupleSerialization.SerializationElementReader
|
static class |
TupleSerialization.SerializationElementWriter
|
Constructor Summary | |
---|---|
TupleSerialization()
Constructor TupleSerialization creates a new TupleSerialization instance. |
|
TupleSerialization(org.apache.hadoop.conf.Configuration conf)
Constructor TupleSerialization creates a new TupleSerialization instance. |
|
TupleSerialization(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess)
|
Method Summary | |
---|---|
boolean |
accept(Class c)
Method accept implements Serialization.accept(Class) . |
static void |
addSerialization(Map<Object,Object> properties,
String className)
Deprecated. |
static void |
addSerializationToken(Map<Object,Object> properties,
int token,
String className)
Deprecated. |
Class |
getClass(String className)
|
Comparator |
getComparator(Class type)
|
org.apache.hadoop.conf.Configuration |
getConf()
|
Comparator |
getDefaultComparator()
|
static Comparator |
getDefaultComparator(Comparator comparator,
org.apache.hadoop.conf.Configuration jobConf)
|
static Comparator |
getDefaultComparator(org.apache.hadoop.conf.Configuration jobConf)
|
org.apache.hadoop.io.serializer.Deserializer |
getDeserializer(Class c)
Method getDeserializer implements Serialization.getDeserializer(Class) . |
TupleSerialization.SerializationElementReader |
getElementReader()
Method getElementReader returns the elementReader of this TupleSerialization object. |
TupleSerialization.SerializationElementWriter |
getElementWriter()
Method getElementWriter returns the elementWriter of this TupleSerialization object. |
static String |
getSerializationTokens(Map<Object,Object> properties)
Deprecated. |
org.apache.hadoop.io.serializer.Serializer |
getSerializer(Class c)
Method getSerializer implements Serialization.getSerializer(Class) . |
void |
setConf(org.apache.hadoop.conf.Configuration conf)
|
static void |
setSerializations(org.apache.hadoop.mapred.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 |
---|
public TupleSerialization()
public TupleSerialization(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess)
public TupleSerialization(org.apache.hadoop.conf.Configuration conf)
conf
- of type ConfigurationMethod Detail |
---|
@Deprecated public static void addSerializationToken(Map<Object,Object> properties, int token, String className)
TupleSerializationProps.addSerializationToken(java.util.Map, int, String)
.
properties
- of type Maptoken
- of type intclassName
- of type String@Deprecated public static String getSerializationTokens(Map<Object,Object> properties)
TupleSerializationProps.getSerializationTokens(java.util.Map)
.
properties
- of type Map
@Deprecated public static void addSerialization(Map<Object,Object> properties, String className)
TupleSerializationProps.addSerialization(java.util.Map, String)
.
properties
- of type MapclassName
- of type Stringpublic static void setSerializations(org.apache.hadoop.mapred.JobConf jobConf)
TupleSerialization
and WritableSerialization
are
first in the list, as both are required.
jobConf
- of type JobConfpublic static Comparator getDefaultComparator(Comparator comparator, org.apache.hadoop.conf.Configuration jobConf)
public static Comparator getDefaultComparator(org.apache.hadoop.conf.Configuration jobConf)
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class org.apache.hadoop.conf.Configured
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
getConf
in class org.apache.hadoop.conf.Configured
public Comparator getDefaultComparator()
public Comparator getComparator(Class type)
public TupleSerialization.SerializationElementReader getElementReader()
public TupleSerialization.SerializationElementWriter getElementWriter()
public boolean accept(Class c)
Serialization.accept(Class)
.
accept
in interface org.apache.hadoop.io.serializer.Serialization
c
- of type Class
public org.apache.hadoop.io.serializer.Deserializer getDeserializer(Class c)
Serialization.getDeserializer(Class)
.
getDeserializer
in interface org.apache.hadoop.io.serializer.Serialization
c
- of type Class
public org.apache.hadoop.io.serializer.Serializer getSerializer(Class c)
Serialization.getSerializer(Class)
.
getSerializer
in interface org.apache.hadoop.io.serializer.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 |