public class TupleSerialization extends Configured implements Serialization
Serialization
interface.
Typically developers will not use this implementation directly as it is automatically added
to any relevant MapReduce jobs via the Configuration
.
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.Modifier and Type | Class and Description |
---|---|
static class |
TupleSerialization.SerializationElementReader |
static class |
TupleSerialization.SerializationElementWriter |
Constructor and Description |
---|
TupleSerialization()
Constructor TupleSerialization creates a new TupleSerialization instance.
|
TupleSerialization(Configuration conf)
Constructor TupleSerialization creates a new TupleSerialization instance.
|
TupleSerialization(FlowProcess<? extends Configuration> flowProcess) |
public TupleSerialization()
public TupleSerialization(FlowProcess<? extends Configuration> flowProcess)
public TupleSerialization(Configuration conf)
conf
- of type Configurationpublic static void setSerializations(Configuration jobConf)
TupleSerialization
and WritableSerialization
are
first in the list, as both are required.jobConf
- of type JobConfpublic static Comparator getDefaultComparator(Comparator comparator, Configuration jobConf)
public static Comparator getDefaultComparator(Configuration jobConf)
public void setConf(Configuration conf)
setConf
in interface Configurable
setConf
in class Configured
public Configuration getConf()
getConf
in interface Configurable
getConf
in class Configured
public boolean areTypesIgnored()
public boolean areTypesRequired()
public Fields getKeyFields()
public Class[] getKeyTypes()
public Class[] getTypesFor(Fields fields)
public Fields getSortFields()
public Class[] getSortTypes()
public Fields getValueFields()
public Fields getMaskedValueFields()
public Class[] getValueTypes()
public Map<Integer,Class[]> getKeyTypeMap()
public Map<Integer,Class[]> getValueTypeMap()
public Map<Integer,Class[]> getMaskedValueTypeMap()
public List<Integer> getOrdinals()
public Integer getFirstOrdinal()
public Map<Integer,Fields> getKeyFieldsMap()
public Map<Integer,Fields> getSortFieldsMap()
public Map<Integer,Fields> getValueFieldsMap()
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 Serialization
c
- of type Classpublic Deserializer getDeserializer(Class c)
Serialization.getDeserializer(Class)
.getDeserializer
in interface Serialization
c
- of type Classpublic Serializer getSerializer(Class c)
Serialization.getSerializer(Class)
.getSerializer
in interface Serialization
c
- of type ClassCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.