com.impetus.client.cassandra.schemamanager

Class CassandraDataTranslator

java.lang.Object

com.impetus.client.cassandra.schemamanager.CassandraDataTranslator

public final class CassandraDataTranslator
extends Object

Class to decompose and compose Cassandra data type objects.

Author:

chhavi.gangwal

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CassandraDataTranslator.CassandraType CassandradataType enum.

Constructor Summary

Constructors

Constructor and Description
CassandraDataTranslator()

Method Summary

Methods

Modifier and Type	Method and Description
static byte[]	compose(Class<?> dataTypeClazz, Object dataValue, boolean isCql3Enabled) Calls compose function of respective data type of object.
static byte[]	compose(Class<?> dataTypeClazz, Object dataValue, Class<?> mapGenericClassses, boolean isCql3Enabled) Calls compose function of respective data type of object.
static byte[]	compose(Class<?> dataTypeClazz, Object dataValue, List<Class<?>> mapGenericClassses, boolean isCql3Enabled) Calls compose function of respective data type of object.
static Object	decompose(Class<?> dataTypeClazz, Object dataValue, boolean isCql3Enabled) Calls decompose function of respective data type of object.
static Object	decompose(Class<?> dataTypeClazz, Object dataValue, Class<?> mapGenericClassses, boolean isCql3Enabled) Calls decompose function of respective data type of object.
static Object	decompose(Class<?> dataTypeClazz, Object dataValue, List<Class<?>> mapGenericClassses, boolean isCql3Enabled) Calls decompose function of respective data type of object.
static CassandraDataTranslator.CassandraType	getCassandraDataTypeClass(Class clazz) Gets the cassandra data type class.
static boolean	isCassandraDataTypeClass(Class clazz) Checks whether the data type object is that of cassandra.
static Collection	marshalCollection(Class cassandraTypeClazz, Collection result, Class clazz, Class resultTypeClass) Marshal collection.
static Map	marshalMap(List<Class<?>> mapGenericClasses, Class keyClass, Class valueClass, Map rawMap) In case, key or value class is of type blob.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraDataTranslator

public CassandraDataTranslator()

Method Detail

getCassandraDataTypeClass

public static CassandraDataTranslator.CassandraType getCassandraDataTypeClass(Class clazz)

Gets the cassandra data type class.

Parameters:

clazz - the clazz

Returns:

the cassandra data type class

isCassandraDataTypeClass

public static boolean isCassandraDataTypeClass(Class clazz)

Checks whether the data type object is that of cassandra.

Parameters:

clazz - the clazz

Returns:

true, if is cassandra data type class

compose

public static byte[] compose(Class<?> dataTypeClazz,
             Object dataValue,
             boolean isCql3Enabled)

Calls compose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

isCql3Enabled - the is cql3 enabled

Returns:

the byte[]

compose

public static byte[] compose(Class<?> dataTypeClazz,
             Object dataValue,
             List<Class<?>> mapGenericClassses,
             boolean isCql3Enabled)

Calls compose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

mapGenericClassses - the map generic classses

isCql3Enabled - the is cql3 enabled

Returns:

the byte[]

compose

public static byte[] compose(Class<?> dataTypeClazz,
             Object dataValue,
             Class<?> mapGenericClassses,
             boolean isCql3Enabled)

Calls compose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

mapGenericClassses - the map generic classses

isCql3Enabled - the is cql3 enabled

Returns:

the byte[]

decompose

public static Object decompose(Class<?> dataTypeClazz,
               Object dataValue,
               boolean isCql3Enabled)

Calls decompose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

isCql3Enabled - the is cql3 enabled

Returns:

the object

decompose

public static Object decompose(Class<?> dataTypeClazz,
               Object dataValue,
               List<Class<?>> mapGenericClassses,
               boolean isCql3Enabled)

Calls decompose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

mapGenericClassses - the map generic classses

isCql3Enabled - the is cql3 enabled

Returns:

the object

decompose

public static Object decompose(Class<?> dataTypeClazz,
               Object dataValue,
               Class<?> mapGenericClassses,
               boolean isCql3Enabled)

Calls decompose function of respective data type of object.

Parameters:

dataTypeClazz - the data type clazz

dataValue - the data value

mapGenericClassses - the map generic classses

isCql3Enabled - the is cql3 enabled

Returns:

the object

marshalMap

public static Map marshalMap(List<Class<?>> mapGenericClasses,
             Class keyClass,
             Class valueClass,
             Map rawMap)

In case, key or value class is of type blob. Iterate and populate corresponding byte[]

Parameters:

mapGenericClasses - the map generic classes

keyClass - the key class

valueClass - the value class

rawMap - the raw map

Returns:

the map

marshalCollection

public static Collection marshalCollection(Class cassandraTypeClazz,
                           Collection result,
                           Class clazz,
                           Class resultTypeClass)

Marshal collection.

Parameters:

cassandraTypeClazz - the cassandra type clazz

result - the result

clazz - the clazz

Returns:

the collection