com.impetus.client.cassandra.index

Class InvertedIndexHandlerBase

java.lang.Object

com.impetus.client.cassandra.index.InvertedIndexHandlerBase

Direct Known Subclasses:

ThriftInvertedIndexHandler

public abstract class InvertedIndexHandlerBase
extends Object

Base class for

Author:

amresh.singh

Field Summary

Fields

Modifier and Type	Field and Description
protected TimestampGenerator	generator For time stamp generation.
protected boolean	useSecondryIndex

Constructor Summary

Constructors

Constructor and Description
InvertedIndexHandlerBase(TimestampGenerator generator)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(Object entity, EntityMetadata metadata, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)
protected abstract void	deleteColumn(String indexColumnFamily, String rowKey, byte[] superColumnName, String persistenceUnit, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, byte[] columnName)
protected abstract org.apache.cassandra.thrift.SuperColumn	getSuperColumnForRow(org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, String columnFamilyName, String rowKey, byte[] superColumnName, String persistenceUnit)
List<SearchResult>	search(EntityMetadata m, String persistenceUnit, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)
protected abstract void	searchSuperColumnsInRange(String columnFamilyName, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, String persistenceUnit, String rowKey, byte[] searchSuperColumnName, List<org.apache.cassandra.thrift.SuperColumn> thriftSuperColumns, byte[] start, byte[] finish)

Methods inherited from class java.lang.Object

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

Field Detail

useSecondryIndex

protected boolean useSecondryIndex

generator

protected final TimestampGenerator generator

For time stamp generation.

Constructor Detail

InvertedIndexHandlerBase

public InvertedIndexHandlerBase(TimestampGenerator generator)

Method Detail

search

public List<SearchResult> search(EntityMetadata m,
                        String persistenceUnit,
                        org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
                        Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)

delete

public void delete(Object entity,
          EntityMetadata metadata,
          org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
          EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)

deleteColumn

protected abstract void deleteColumn(String indexColumnFamily,
                String rowKey,
                byte[] superColumnName,
                String persistenceUnit,
                org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
                byte[] columnName)

Parameters:

indexColumnFamily -

rowKey -

superColumnName -

columnName - TODO

getSuperColumnForRow

protected abstract org.apache.cassandra.thrift.SuperColumn getSuperColumnForRow(org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
                                                           String columnFamilyName,
                                                           String rowKey,
                                                           byte[] superColumnName,
                                                           String persistenceUnit)

Parameters:

consistencyLevel -

columnFamilyName -

rowKey -

superColumnName -

Returns:

searchSuperColumnsInRange

protected abstract void searchSuperColumnsInRange(String columnFamilyName,
                             org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
                             String persistenceUnit,
                             String rowKey,
                             byte[] searchSuperColumnName,
                             List<org.apache.cassandra.thrift.SuperColumn> thriftSuperColumns,
                             byte[] start,
                             byte[] finish)