Package | Description |
---|---|
com.hp.util.persistence.cassandra |
...
|
com.hp.util.persistence.cassandra.index |
...
|
com.hp.util.persistence.cassandra.query |
...
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractBaseDao.count(F filter,
DataStoreContext context) |
protected Long |
AbstractBaseDao.countByFilter(F filter,
DataStoreContext context)
Given a filter, count the number of rows that match it.
|
P |
CassAbstractDao.create(T transportable,
DataStoreContext context)
Creates a new persistent object with the data from the given transport
object.
|
long |
CassAbstractDao.delete(F filter,
DataStoreContext context) |
<E extends T> |
CassAbstractDao.delete(Id<E,I> id,
DataStoreContext context) |
long |
CassAbstractDao.deleteAll(DataStoreContext context) |
List<P> |
AbstractBaseDao.find(F filter,
SortSpecification<S> sortSpecification,
DataStoreContext context)
Get the list of persistent objects based on the given filter criteria.
|
MarkPage<P> |
AbstractBaseDao.find(F filter,
SortSpecification<S> sortSpecification,
MarkPageRequest<?> request,
DataStoreContext context) |
List<P> |
AbstractBaseDao.findAll(SortSpecification<S> sortSpecification,
DataStoreContext context) |
protected abstract <M> MarkPage<I> |
AbstractBaseDao.findPagedRows(F filter,
SortSpecification<S> sortSpecification,
MarkPageRequest<M> request,
DataStoreContext context) |
protected abstract Collection<I> |
AbstractBaseDao.findRows(F filter,
DataStoreContext context) |
P |
AbstractBaseDao.get(I id,
DataStoreContext context) |
void |
CfQueryOperations.prepareDelete(T id,
DataStoreContext context)
CfQueryOperations.prepareDelete(T, com.hp.util.persistence.cassandra.DataStoreContext) implements the Delete
operation for every CF |
void |
CfQueryOperations.prepareMutation(T transportable,
DataStoreContext context)
CfQueryOperations.prepareMutation(T, com.hp.util.persistence.cassandra.DataStoreContext) mandates the implementation
of preparation of Write operation for every Column Family
implementing this interface. |
void |
CfQueryOperations.prepareTransaction(T transportable,
DataStoreContext context) |
void |
CfQueryOperations.prepareUpdate(T oldT,
T newT,
DataStoreContext context)
CfQueryOperations.prepareMutation(T, com.hp.util.persistence.cassandra.DataStoreContext) mandates the implementation
of preparation of Write operation for every Column Family
implementing this interface. |
P |
CassAbstractDao.update(T transportable,
DataStoreContext context)
This method is used to update existing column values.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
DataStoreManager.execute(ReadQuery<T,DataStoreContext> query)
DataStoreManager#execute(ReadQuery) provides an implementation
to execute a Read operation on the persistent database.
|
<T> T |
DataStoreManager.execute(WriteQuery<T,DataStoreContext> update)
DataStoreManager#execute(WriteQuery) provides an implementation
to execute a Read operation on the persistent database.
|
Modifier and Type | Method and Description |
---|---|
void |
IndexEntryHandler.addIndexedValue(K rowKey,
Column<String,?> indexedColumn,
DataStoreContext context)
Adds an indexed value.
|
void |
GenericCustomSecondaryIndex.clear(DataStoreContext context) |
void |
CustomSecondaryIndex.clear(DataStoreContext context)
Updates the index after deleting all rows from the main column family.
|
void |
AllRowsSecondaryIndex.clear(DataStoreContext context)
Updates the index after deleting all rows from the main column family.
|
long |
AllRowsSecondaryIndex.count(DataStoreContext context)
Counts all the rows in the main column family or the number of columns in the index column
family.
|
long |
GenericCustomSecondaryIndex.count(K indexKey,
DataStoreContext context) |
long |
CustomSecondaryIndex.count(K indexKey,
DataStoreContext context)
Counts the number of columns in the index.
|
void |
AllRowsSecondaryIndex.delete(C indexEntry,
DataStoreContext context)
Updates the index after a row has been deleted from the main column family.
|
void |
GenericCustomSecondaryIndex.delete(C indexEntry,
K indexKey,
DataStoreContext context) |
void |
CustomSecondaryIndex.delete(C indexEntry,
K indexKey,
DataStoreContext context)
Updates the index after a row has been deleted from the main column family.
|
void |
GenericCustomSecondaryIndex.delete(K indexKey,
DataStoreContext context) |
void |
CustomSecondaryIndex.delete(K indexKey,
DataStoreContext context)
Deletes a row in the secondary index column family.
|
<D> void |
IndexEntryHandler.deleteIndexedValues(K rowKey,
Collection<Column<IndexEntryHandler.IndexEntry,D>> indexedValues,
DataStoreContext context)
Deletes the given indexed values (old values).
|
<D> Collection<Column<IndexEntryHandler.IndexEntry,D>> |
IndexEntryHandler.getIndexedValues(K rowKey,
ColumnName<String,?> indexedColumnName,
ColumnDecoder<IndexEntryHandler.IndexEntry,D> decoder,
DataStoreContext context)
Gets the indexed values (old values).
|
void |
AllRowsSecondaryIndex.insert(C indexEntry,
D denormalizedData,
DataStoreContext context)
Updates the index after a row has been inserted into the main column family.
|
void |
GenericCustomSecondaryIndex.insert(C indexEntry,
D denormalizedData,
K indexKey,
DataStoreContext context) |
void |
CustomSecondaryIndex.insert(C indexEntry,
D denormalizedData,
K indexKey,
DataStoreContext context)
Updates the index after a row has been inserted into the main column
family.
|
List<Column<C,D>> |
AllRowsSecondaryIndex.read(DataStoreContext context)
Reads the index entries.
|
List<Column<C,D>> |
GenericCustomSecondaryIndex.read(K indexKey,
DataStoreContext context) |
List<Column<C,D>> |
CustomSecondaryIndex.read(K indexKey,
DataStoreContext context)
Reads the index entries.
|
List<Column<C,D>> |
AllRowsSecondaryIndex.read(List<C> indexEntries,
DataStoreContext context)
Reads the index entries.
|
List<Column<C,D>> |
GenericCustomSecondaryIndex.read(List<C> indexEntries,
K indexKey,
DataStoreContext context) |
List<Column<C,D>> |
CustomSecondaryIndex.read(List<C> indexEntries,
K indexKey,
DataStoreContext context)
Reads the index entries.
|
Modifier and Type | Method and Description |
---|---|
T |
TransWriteWithSelStarDecorator.execute(DataStoreContext context) |
T |
TransWriteQueryDecorator.execute(DataStoreContext context) |
T |
TransReadQueryDecorator.execute(DataStoreContext context) |
List<T> |
TransReadAllDecorator.execute(DataStoreContext context) |
Constructor and Description |
---|
TransReadAllDecorator(ReadQuery<List<T>,DataStoreContext> query) |
TransReadQueryDecorator(ReadQuery<T,DataStoreContext> query) |
TransWriteQueryDecorator(WriteQuery<T,DataStoreContext> update)
Constructor for Write Query Decorator with locks.
|
Copyright © 2015. All Rights Reserved.