com.netflix.astyanax.serializers
Class SerializerPackageImpl

java.lang.Object
  extended by com.netflix.astyanax.serializers.SerializerPackageImpl
All Implemented Interfaces:
SerializerPackage

public class SerializerPackageImpl
extends Object
implements SerializerPackage

Basic implementation of SerializerPackage which can be configured either from a ColumnFamilyDefinition or by manually setting either the ComparatorType or Serializer for keys, columns and values. Use this in conjunction with the CSV uploader to specify how values are serializer.

Author:
elandau

Field Summary
static SerializerPackage DEFAULT_SERIALIZER_PACKAGE
           
 
Constructor Summary
SerializerPackageImpl()
           
SerializerPackageImpl(ColumnFamilyDefinition cfDef, boolean ignoreErrors)
          Construct a serializer package from a column family definition retrieved from the keyspace.
 
Method Summary
 ByteBuffer columnAsByteBuffer(String column)
          Convert a string column name to a ByteBuffer using the package's column serializer
 String columnAsString(ByteBuffer column)
          Convert a column name to a string using the package's column serializer
 Set<ByteBuffer> getColumnNames()
          Return the set of supported column names
 Serializer<?> getColumnNameSerializer()
          Return serializer for column names
 Serializer<?> getColumnSerializer()
          Deprecated. 
 Serializer<?> getColumnSerializer(ByteBuffer columnName)
          Return the value serializer for the specified column name
 Serializer<?> getColumnSerializer(String columnName)
          Return the value serializer for the specified column name
 Serializer<?> getDefaultValueSerializer()
          Return the default value serializer
 Serializer<?> getKeySerializer()
          Return the serializer for keys
 Serializer<?> getValueSerializer()
          Deprecated. 
 Serializer<?> getValueSerializer(ByteBuffer columnName)
          Deprecated. 
 Serializer<?> getValueSerializer(String columnName)
          Deprecated. 
 ByteBuffer keyAsByteBuffer(String key)
          Convert a string key to a ByteBuffer using the package's key serializer
 String keyAsString(ByteBuffer key)
          Convert a key to a string using the package's key serializer
 SerializerPackageImpl setColumnNameSerializer(Serializer<?> serializer)
           
 SerializerPackageImpl setColumnNameType(String columnType)
           
 SerializerPackageImpl setColumnType(String columnType)
          Deprecated. 
 SerializerPackageImpl setDefaultValueSerializer(Serializer<?> serializer)
           
 SerializerPackageImpl setDefaultValueType(String valueType)
           
 SerializerPackageImpl setKeySerializer(Serializer<?> serializer)
           
 SerializerPackageImpl setKeyType(String keyType)
           
 SerializerPackageImpl setValueSerializer(ByteBuffer columnName, Serializer<?> serializer)
           
 SerializerPackageImpl setValueSerializer(String columnName, Serializer<?> serializer)
           
 SerializerPackageImpl setValueType(ByteBuffer columnName, String valueType)
           
 SerializerPackageImpl setValueType(String columnName, String type)
           
 ByteBuffer valueAsByteBuffer(ByteBuffer column, String value)
          Convert a string value to a string using the package's value serializer
 ByteBuffer valueAsByteBuffer(String column, String value)
          Convert a string value to a string using the package's value serializer
 String valueAsString(ByteBuffer column, ByteBuffer value)
          Convert a value to a string using the package's value serializer.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_SERIALIZER_PACKAGE

public static final SerializerPackage DEFAULT_SERIALIZER_PACKAGE
Constructor Detail

SerializerPackageImpl

public SerializerPackageImpl()

SerializerPackageImpl

public SerializerPackageImpl(ColumnFamilyDefinition cfDef,
                             boolean ignoreErrors)
                      throws UnknownComparatorException
Construct a serializer package from a column family definition retrieved from the keyspace. This is the preferred method of initialing the serializer since it most closely matches the validators and comparator type set in cassandra.

Parameters:
cfDef -
ignoreErrors -
Throws:
UnknownComparatorException
Method Detail

setKeyType

public SerializerPackageImpl setKeyType(String keyType)
                                 throws UnknownComparatorException
Throws:
UnknownComparatorException

setKeySerializer

public SerializerPackageImpl setKeySerializer(Serializer<?> serializer)

setColumnType

@Deprecated
public SerializerPackageImpl setColumnType(String columnType)
                                    throws UnknownComparatorException
Deprecated. 

Throws:
UnknownComparatorException

setColumnNameType

public SerializerPackageImpl setColumnNameType(String columnType)
                                        throws UnknownComparatorException
Throws:
UnknownComparatorException

setColumnNameSerializer

public SerializerPackageImpl setColumnNameSerializer(Serializer<?> serializer)

setDefaultValueType

public SerializerPackageImpl setDefaultValueType(String valueType)
                                          throws UnknownComparatorException
Throws:
UnknownComparatorException

setDefaultValueSerializer

public SerializerPackageImpl setDefaultValueSerializer(Serializer<?> serializer)

setValueType

public SerializerPackageImpl setValueType(String columnName,
                                          String type)
                                   throws UnknownComparatorException
Throws:
UnknownComparatorException

setValueType

public SerializerPackageImpl setValueType(ByteBuffer columnName,
                                          String valueType)
                                   throws UnknownComparatorException
Throws:
UnknownComparatorException

setValueSerializer

public SerializerPackageImpl setValueSerializer(String columnName,
                                                Serializer<?> serializer)

setValueSerializer

public SerializerPackageImpl setValueSerializer(ByteBuffer columnName,
                                                Serializer<?> serializer)

getKeySerializer

public Serializer<?> getKeySerializer()
Description copied from interface: SerializerPackage
Return the serializer for keys

Specified by:
getKeySerializer in interface SerializerPackage
Returns:

getColumnSerializer

@Deprecated
public Serializer<?> getColumnSerializer()
Deprecated. 

Specified by:
getColumnSerializer in interface SerializerPackage

getColumnNameSerializer

public Serializer<?> getColumnNameSerializer()
Description copied from interface: SerializerPackage
Return serializer for column names

Specified by:
getColumnNameSerializer in interface SerializerPackage
Returns:

getValueSerializer

@Deprecated
public Serializer<?> getValueSerializer(ByteBuffer columnName)
Deprecated. 

Specified by:
getValueSerializer in interface SerializerPackage

getColumnSerializer

public Serializer<?> getColumnSerializer(ByteBuffer columnName)
Description copied from interface: SerializerPackage
Return the value serializer for the specified column name

Specified by:
getColumnSerializer in interface SerializerPackage
Returns:

getColumnSerializer

public Serializer<?> getColumnSerializer(String columnName)
Description copied from interface: SerializerPackage
Return the value serializer for the specified column name

Specified by:
getColumnSerializer in interface SerializerPackage
Returns:

getValueSerializer

@Deprecated
public Serializer<?> getValueSerializer(String columnName)
Deprecated. 

Specified by:
getValueSerializer in interface SerializerPackage

getColumnNames

public Set<ByteBuffer> getColumnNames()
Description copied from interface: SerializerPackage
Return the set of supported column names

Specified by:
getColumnNames in interface SerializerPackage
Returns:

getValueSerializer

@Deprecated
public Serializer<?> getValueSerializer()
Deprecated. 

Specified by:
getValueSerializer in interface SerializerPackage
Returns:

getDefaultValueSerializer

public Serializer<?> getDefaultValueSerializer()
Description copied from interface: SerializerPackage
Return the default value serializer

Specified by:
getDefaultValueSerializer in interface SerializerPackage
Returns:

keyAsString

public String keyAsString(ByteBuffer key)
Description copied from interface: SerializerPackage
Convert a key to a string using the package's key serializer

Specified by:
keyAsString in interface SerializerPackage
Returns:

columnAsString

public String columnAsString(ByteBuffer column)
Description copied from interface: SerializerPackage
Convert a column name to a string using the package's column serializer

Specified by:
columnAsString in interface SerializerPackage
Returns:

valueAsString

public String valueAsString(ByteBuffer column,
                            ByteBuffer value)
Description copied from interface: SerializerPackage
Convert a value to a string using the package's value serializer. Will use either a column specific serializer, if one was specified, or the default value serializer.

Specified by:
valueAsString in interface SerializerPackage
Returns:

keyAsByteBuffer

public ByteBuffer keyAsByteBuffer(String key)
Description copied from interface: SerializerPackage
Convert a string key to a ByteBuffer using the package's key serializer

Specified by:
keyAsByteBuffer in interface SerializerPackage
Returns:

columnAsByteBuffer

public ByteBuffer columnAsByteBuffer(String column)
Description copied from interface: SerializerPackage
Convert a string column name to a ByteBuffer using the package's column serializer

Specified by:
columnAsByteBuffer in interface SerializerPackage
Returns:

valueAsByteBuffer

public ByteBuffer valueAsByteBuffer(ByteBuffer column,
                                    String value)
Description copied from interface: SerializerPackage
Convert a string value to a string using the package's value serializer

Specified by:
valueAsByteBuffer in interface SerializerPackage
Returns:

valueAsByteBuffer

public ByteBuffer valueAsByteBuffer(String column,
                                    String value)
Description copied from interface: SerializerPackage
Convert a string value to a string using the package's value serializer

Specified by:
valueAsByteBuffer in interface SerializerPackage
Returns:


Copyright © 2012. All Rights Reserved.