public class TupleSerializationProps extends Props
FlowConnector
before creating new Flow
instances.
See TupleSerialization
for details on these properties.TupleSerialization
Modifier and Type | Field and Description |
---|---|
static String |
HADOOP_IO_SERIALIZATIONS |
static String |
SERIALIZATION_TOKENS |
Constructor and Description |
---|
TupleSerializationProps() |
Modifier and Type | Method and Description |
---|---|
TupleSerializationProps |
addHadoopSerialization(String hadoopSerializationClassName)
Method addHadoopSerialization adds a Hadoop serialization className to be used as properties.
|
TupleSerializationProps |
addHadoopSerializations(List<String> hadoopSerializationClassNames)
Method addHadoopSerializations adds the Hadoop serialization classNames to be used as properties.
|
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 serializationClassName)
Method addSerializationToken adds the given integer token and classNames as a serialization properties.
|
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)
Method addSerializationTokens adds the given integer tokens and classNames Map as a serialization properties.
|
List<String> |
getHadoopSerializations() |
Map<Integer,String> |
getSerializationTokens() |
static String |
getSerializationTokens(Map<Object,Object> properties)
Returns the serialization tokens property.
|
TupleSerializationProps |
setHadoopSerializations(List<String> hadoopSerializationClassNames)
Method setHadoopSerializations sets the Hadoop serialization classNames to be used as properties.
|
TupleSerializationProps |
setSerializationTokens(Map<Integer,String> serializationTokens)
Method setSerializationTokens sets the given integer tokens and classNames Map as a serialization properties.
|
static TupleSerializationProps |
tupleSerializationProps()
Creates a new TupleSerializationProps instance.
|
buildProperties, buildProperties, buildProperties, buildProperties, setProperties, setProperties
public static final String SERIALIZATION_TOKENS
public static final String HADOOP_IO_SERIALIZATIONS
public TupleSerializationProps()
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 Mappublic static void addSerialization(Map<Object,Object> properties, String className)
properties
- of type MapclassName
- of type Stringpublic static TupleSerializationProps tupleSerializationProps()
public Map<Integer,String> getSerializationTokens()
public TupleSerializationProps setSerializationTokens(Map<Integer,String> serializationTokens)
serializationTokens
- Map of Integer tokens and String classnamespublic TupleSerializationProps addSerializationTokens(Map<Integer,String> serializationTokens)
serializationTokens
- Map of Integer tokens and String classnamespublic TupleSerializationProps addSerializationToken(int token, String serializationClassName)
token
- type intserializationClassName
- type Stringpublic List<String> getHadoopSerializations()
public TupleSerializationProps setHadoopSerializations(List<String> hadoopSerializationClassNames)
hadoopSerializationClassNames
- List of classNamespublic TupleSerializationProps addHadoopSerializations(List<String> hadoopSerializationClassNames)
hadoopSerializationClassNames
- List of classNamespublic TupleSerializationProps addHadoopSerialization(String hadoopSerializationClassName)
hadoopSerializationClassName
- List of classNamesprotected void addPropertiesTo(Properties properties)
addPropertiesTo
in class Props
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.