cascading.tuple.hadoop
Class TupleSerializationProps

java.lang.Object
  extended by cascading.property.Props
      extended by 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

Field Summary
static String HADOOP_IO_SERIALIZATIONS
           
static String SERIALIZATION_TOKENS
           
 
Constructor Summary
TupleSerializationProps()
           
 
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 cascading.property.Props
buildProperties, buildProperties, buildProperties, buildProperties, setProperties, setProperties
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

TupleSerializationProps

public TupleSerializationProps()
Method Detail

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 Map
token - of type int
className - 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 Map
className - 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.