com.impetus.client.cassandra.thrift

Class ThriftInvertedIndexHandler

java.lang.Object

com.impetus.client.cassandra.index.InvertedIndexHandlerBase

com.impetus.client.cassandra.thrift.ThriftInvertedIndexHandler

All Implemented Interfaces:

InvertedIndexHandler

public class ThriftInvertedIndexHandler
extends InvertedIndexHandlerBase
implements InvertedIndexHandler

Thrift implementation of InvertedIndexHandler.

Author:

amresh.singh

Field Summary

Fields inherited from class com.impetus.client.cassandra.index.InvertedIndexHandlerBase

generator, useSecondryIndex

Constructor Summary

Constructors

Constructor and Description
ThriftInvertedIndexHandler(ThriftClient thriftClient, boolean useSecondryIndex, TimestampGenerator generator) Instantiates a new thrift inverted index handler.

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(Object entity, EntityMetadata metadata, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata) Deletes a record from inverted index table.
protected void	deleteColumn(String indexColumnFamily, String rowKey, byte[] superColumnName, String persistenceUnit, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, byte[] columnName)
protected 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) Searches records from Inverted index table.
protected 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)
void	write(Node node, EntityMetadata entityMetadata, String persistenceUnit, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel, CassandraDataHandler cdHandler) Writes a record into inverted index table.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThriftInvertedIndexHandler

public ThriftInvertedIndexHandler(ThriftClient thriftClient,
                          boolean useSecondryIndex,
                          TimestampGenerator generator)

Instantiates a new thrift inverted index handler.

Parameters:

thriftClient - the thrift client

useSecondryIndex - the use secondry index

generator - the generator

Method Detail

write

public void write(Node node,
         EntityMetadata entityMetadata,
         String persistenceUnit,
         org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel,
         CassandraDataHandler cdHandler)

Description copied from interface: InvertedIndexHandler

Writes a record into inverted index table.

Specified by:

write in interface InvertedIndexHandler

search

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

Description copied from interface: InvertedIndexHandler

Searches records from Inverted index table.

Specified by:

search in interface InvertedIndexHandler

Overrides:

search in class InvertedIndexHandlerBase

Returns:

searchSuperColumnsInRange

protected 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)

Specified by:

searchSuperColumnsInRange in class InvertedIndexHandlerBase

getSuperColumnForRow

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

Specified by:

getSuperColumnForRow in class InvertedIndexHandlerBase

Returns:

delete

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

Description copied from interface: InvertedIndexHandler

Deletes a record from inverted index table.

Specified by:

delete in interface InvertedIndexHandler

Overrides:

delete in class InvertedIndexHandlerBase

deleteColumn

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

Specified by:

deleteColumn in class InvertedIndexHandlerBase

columnName - TODO