com.impetus.client.cassandra.query

Class CassandraEntityReader

java.lang.Object

com.impetus.kundera.persistence.AbstractEntityReader

com.impetus.client.cassandra.query.CassandraEntityReader

All Implemented Interfaces:

EntityReader

public class CassandraEntityReader
extends AbstractEntityReader
implements EntityReader

The Class CassandraEntityReader.

Author:

vivek.mishra

Field Summary

Fields inherited from class com.impetus.kundera.persistence.AbstractEntityReader

kunderaMetadata, kunderaQuery

Constructor Summary

Constructors

Constructor and Description
CassandraEntityReader(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata) Instantiates a new cassandra entity reader.
CassandraEntityReader(KunderaQuery kunderaQuery, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata) Instantiates a new cassandra entity reader.

Method Summary

Methods

Modifier and Type	Method and Description
EnhanceEntity	findById(Object primaryKey, EntityMetadata m, Client client)
List	handleFindByRange(EntityMetadata m, Client client, List result, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> ixClause, boolean isRowKeyQuery, List<String> columns, int maxResults) Handle find by range.
List<EnhanceEntity>	populateRelation(EntityMetadata m, Client client, int maxResults) Method responsible for reading back entity and relations using secondary indexes(if it holds any relation), else retrieve row keys using lucene.
List<EnhanceEntity>	readFromIndexTable(EntityMetadata m, Client client, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap) Read from index table.
void	setConditions(Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> conditions) Method to set indexcluase conditions.

Methods inherited from class com.impetus.kundera.persistence.AbstractEntityReader

fetchDataFromLucene, getId, onAssociationUsingLucene, recursivelyFindEntities, transform

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.impetus.kundera.persistence.EntityReader

recursivelyFindEntities

Constructor Detail

CassandraEntityReader

public CassandraEntityReader(KunderaQuery kunderaQuery,
                     EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)

Instantiates a new cassandra entity reader.

Parameters:

kunderaQuery - the kundera query

kunderaMetadata - the kundera metadata

CassandraEntityReader

public CassandraEntityReader(EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)

Instantiates a new cassandra entity reader.

Parameters:

kunderaMetadata - the kundera metadata

Method Detail

findById

public EnhanceEntity findById(Object primaryKey,
                     EntityMetadata m,
                     Client client)

Specified by:

findById in interface EntityReader

Overrides:

findById in class AbstractEntityReader

populateRelation

public List<EnhanceEntity> populateRelation(EntityMetadata m,
                                   Client client,
                                   int maxResults)

Method responsible for reading back entity and relations using secondary indexes(if it holds any relation), else retrieve row keys using lucene.

Specified by:

populateRelation in interface EntityReader

Parameters:

m - entity meta data

client - client instance

maxResults - the max results

Returns:

list of wrapped enhance entities.

handleFindByRange

public List handleFindByRange(EntityMetadata m,
                     Client client,
                     List result,
                     Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> ixClause,
                     boolean isRowKeyQuery,
                     List<String> columns,
                     int maxResults)

Handle find by range.

Parameters:

m - the m

client - the client

result - the result

ixClause - the ix clause

isRowKeyQuery - the is row key query

columns - the columns

maxResults - the max results

Returns:

the list

readFromIndexTable

public List<EnhanceEntity> readFromIndexTable(EntityMetadata m,
                                     Client client,
                                     Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)

Read from index table.

Parameters:

m - the m

client - the client

indexClauseMap - the index clause map

Returns:

the list

setConditions

public void setConditions(Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> conditions)

Method to set indexcluase conditions.

Parameters:

conditions - index conditions.