cascading.tuple.hadoop
Class TupleSerializationProps
java.lang.Object
cascading.property.Props
cascading.tuple.hadoop.TupleSerializationProps
public class TupleSerializationProps
- extends Props
Class TupleSerializationProps is a fluent interface for building properties to be passed to a
FlowConnector
before creating new Flow
instances.
See TupleSerialization
for details on these properties.
- See Also:
TupleSerialization
Method Summary |
TupleSerializationProps |
addHadoopSerialization(String hadoopSerialization)
|
TupleSerializationProps |
addHadoopSerializations(List<String> hadoopSerializations)
|
protected void |
addPropertiesTo(Properties properties)
|
static void |
addSerialization(Map<Object,Object> properties,
String className)
Adds the given className as a Hadoop IO serialization class. |
TupleSerializationProps |
addSerializationToken(int token,
String serialization)
|
static void |
addSerializationToken(Map<Object,Object> properties,
int token,
String className)
Adds the given token and className pair as a serialization token property. |
TupleSerializationProps |
addSerializationTokens(Map<Integer,String> serializationTokens)
|
List<String> |
getHadoopSerializations()
|
Map<Integer,String> |
getSerializationTokens()
|
static String |
getSerializationTokens(Map<Object,Object> properties)
Returns the serialization tokens property. |
TupleSerializationProps |
setHadoopSerializations(List<String> hadoopSerializations)
|
TupleSerializationProps |
setSerializationTokens(Map<Integer,String> serializationTokens)
|
static TupleSerializationProps |
tupleSerializationProps()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SERIALIZATION_TOKENS
public static final String SERIALIZATION_TOKENS
- See Also:
- Constant Field Values
HADOOP_IO_SERIALIZATIONS
public static final String HADOOP_IO_SERIALIZATIONS
- See Also:
- Constant Field Values
TupleSerializationProps
public TupleSerializationProps()
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 Maptoken
- of type intclassName
- 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
addSerialization
public static void addSerialization(Map<Object,Object> properties,
String className)
- Adds the given className as a Hadoop IO serialization class.
- Parameters:
properties
- of type MapclassName
- of type String
tupleSerializationProps
public static TupleSerializationProps tupleSerializationProps()
getSerializationTokens
public Map<Integer,String> getSerializationTokens()
setSerializationTokens
public TupleSerializationProps setSerializationTokens(Map<Integer,String> serializationTokens)
addSerializationTokens
public TupleSerializationProps addSerializationTokens(Map<Integer,String> serializationTokens)
addSerializationToken
public TupleSerializationProps addSerializationToken(int token,
String serialization)
getHadoopSerializations
public List<String> getHadoopSerializations()
setHadoopSerializations
public TupleSerializationProps setHadoopSerializations(List<String> hadoopSerializations)
addHadoopSerializations
public TupleSerializationProps addHadoopSerializations(List<String> hadoopSerializations)
addHadoopSerialization
public TupleSerializationProps addHadoopSerialization(String hadoopSerialization)
addPropertiesTo
protected void addPropertiesTo(Properties properties)
- Specified by:
addPropertiesTo
in class Props
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.