com.impetus.client.cassandra.datahandler

Class CassandraDataHandlerBase

java.lang.Object

com.impetus.client.cassandra.datahandler.CassandraDataHandlerBase

Direct Known Subclasses:

ThriftDataHandler

public abstract class CassandraDataHandlerBase
extends Object

Base class for all Cassandra Data Handlers.

Author:

amresh.singh

Field Summary

Fields

Modifier and Type	Field and Description
protected TimestampGenerator	generator The generator.
protected EntityManagerFactoryImpl.KunderaMetadata	kunderaMetadata The kundera metadata.
protected ThriftDataResultHelper	thriftTranslator The thrift translator.

Constructor Summary

Constructors

Constructor and Description
CassandraDataHandlerBase(CassandraClientBase clientBase, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, TimestampGenerator generator) Instantiates a new cassandra data handler base.

Method Summary

Methods

Modifier and Type	Method and Description
List<Object>	fromThriftRow(Class<?> clazz, EntityMetadata m, List<String> relationNames, boolean isWrapReq, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, Object... rowIds) From thrift row.
abstract Object	fromThriftRow(Class<?> clazz, EntityMetadata m, Object rowKey, List<String> relationNames, boolean isWrapReq, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel) From thrift row.
<E> E	fromThriftRow(Class<E> clazz, EntityMetadata m, DataRow<org.apache.cassandra.thrift.SuperColumn> tr) From thrift row.
<E> List<Object>	getForeignKeysFromJoinTable(String inverseJoinColumnName, List<org.apache.cassandra.thrift.Column> columns, Class columnJavaType) Gets the foreign keys from join table.
protected byte[]	getThriftColumnValue(Object e, javax.persistence.metamodel.Attribute attribute) Gets the thrift column value.
Object	populateEmbeddedRecursive(ByteBuffer value, List<org.apache.cassandra.db.marshal.AbstractType<?>> types, List<ByteBuffer> fieldNames, Object entity, MetamodelImpl metaModel) Populate embedded recursive.
Object	populateEntity(ThriftRow tr, EntityMetadata m, Object entity, List<String> relationNames, boolean isWrapReq) Populate entity.
List<ThriftRow>	toIndexThriftRow(Object e, EntityMetadata m, String columnFamily) To index thrift row.
Collection<ThriftRow>	toThriftRow(Object e, Object id, EntityMetadata m, String columnFamily, Object columnTTLs) Helper method to convert @Entity to ThriftRow.

Methods inherited from class java.lang.Object

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

Field Detail

thriftTranslator

protected final ThriftDataResultHelper thriftTranslator

The thrift translator.

kunderaMetadata

protected final EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata

The kundera metadata.

generator

protected final TimestampGenerator generator

The generator.

Constructor Detail

CassandraDataHandlerBase

public CassandraDataHandlerBase(CassandraClientBase clientBase,
                        EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
                        TimestampGenerator generator)

Instantiates a new cassandra data handler base.

Parameters:

clientBase - the client base

kunderaMetadata - the kundera metadata

generator - the generator

Method Detail

fromThriftRow

public <E> E fromThriftRow(Class<E> clazz,
                  EntityMetadata m,
                  DataRow<org.apache.cassandra.thrift.SuperColumn> tr)
                throws Exception

From thrift row.

Type Parameters:

E - the element type

Parameters:

clazz - the clazz

m - the m

tr - the cr

Returns:

the e

Throws:

Exception - the exception

fromThriftRow

public List<Object> fromThriftRow(Class<?> clazz,
                         EntityMetadata m,
                         List<String> relationNames,
                         boolean isWrapReq,
                         org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
                         Object... rowIds)
                           throws Exception

From thrift row.

Parameters:

clazz - the clazz

m - the m

relationNames - the relation names

isWrapReq - the is wrap req

consistencyLevel - the consistency level

rowIds - the row ids

Returns:

the list

Throws:

Exception - the exception

fromThriftRow

public abstract Object fromThriftRow(Class<?> clazz,
                   EntityMetadata m,
                   Object rowKey,
                   List<String> relationNames,
                   boolean isWrapReq,
                   org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel)
                              throws Exception

From thrift row.

Parameters:

clazz - the clazz

m - the m

rowKey - the row key

relationNames - the relation names

isWrapReq - the is wrap req

consistencyLevel - the consistency level

Returns:

the object

Throws:

Exception - the exception

toThriftRow

public Collection<ThriftRow> toThriftRow(Object e,
                                Object id,
                                EntityMetadata m,
                                String columnFamily,
                                Object columnTTLs)
                                  throws Exception

Helper method to convert @Entity to ThriftRow.

Parameters:

e - the e

id - the id

m - the m

columnFamily - the colmun family

columnTTLs - TODO

Returns:

the base data accessor. thrift row

Throws:

Exception - the exception

toIndexThriftRow

public List<ThriftRow> toIndexThriftRow(Object e,
                               EntityMetadata m,
                               String columnFamily)

To index thrift row.

Parameters:

e - the e

m - the m

columnFamily - the column family

Returns:

the list

getForeignKeysFromJoinTable

public <E> List<Object> getForeignKeysFromJoinTable(String inverseJoinColumnName,
                                           List<org.apache.cassandra.thrift.Column> columns,
                                           Class columnJavaType)

Gets the foreign keys from join table.

Type Parameters:

E - the element type

Parameters:

inverseJoinColumnName - the inverse join column name

columns - the columns

columnJavaType - the column java type

Returns:

the foreign keys from join table

populateEntity

public Object populateEntity(ThriftRow tr,
                    EntityMetadata m,
                    Object entity,
                    List<String> relationNames,
                    boolean isWrapReq)

Populate entity.

Parameters:

tr - the tr

m - the m

entity - the entity

relationNames - the relation names

isWrapReq - the is wrap req

Returns:

the object

populateEmbeddedRecursive

public Object populateEmbeddedRecursive(ByteBuffer value,
                               List<org.apache.cassandra.db.marshal.AbstractType<?>> types,
                               List<ByteBuffer> fieldNames,
                               Object entity,
                               MetamodelImpl metaModel)

Populate embedded recursive.

Parameters:

value - the value

types - the types

fieldNames - the field names

entity - the entity

metaModel - the meta model

Returns:

the object

getThriftColumnValue

protected byte[] getThriftColumnValue(Object e,
                          javax.persistence.metamodel.Attribute attribute)

Gets the thrift column value.

Parameters:

e - the e

attribute - the attribute

Returns:

the thrift column value