Package | Description |
---|---|
com.hp.util.persistence |
...
|
com.hp.util.persistence.cassandra |
...
|
com.hp.util.persistence.cassandra.entitymgr |
...
|
Modifier and Type | Method and Description |
---|---|
long |
BaseDao.count(F filter,
C context)
Gets the number of persisted objects based on a filter criteria.
|
Modifier and Type | Method and Description |
---|---|
long |
AbstractBaseDao.count(F filter,
DataStoreContext context) |
ConnectionManager |
ConnectionManagerFactory.create(KeySpaceConfig config) |
<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.
|
Constructor and Description |
---|
AbstractBaseDao()
Construct the DAO and create column families in the persistent database.
|
CassAbstractDao() |
DataStoreManager(EntityManagerFactory emf,
KeySpaceConfig cassandraConfig)
DataStoreManager#DataStoreManager is called from only from the
proxy of this implementation.
|
Modifier and Type | Method and Description |
---|---|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.countColumns(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey)
EntityManager.countColumns(com.netflix.astyanax.model.ColumnFamily<K, C>, K) counts the number of columns in a
given row of a given column family. |
static void |
EntityManager.createColumnFamily(ColumnFamilyDefinition<?,?> cf)
EntityManager.createColumnFamily(com.hp.util.persistence.cassandra.entitymgr.ColumnFamilyDefinition<?, ?>) creates a new Cassandra
Column Family.This method is a single way to create a Cassandra
Column Family in the DAO framework. |
static void |
EntityManager.dropColumnFamily(com.netflix.astyanax.model.ColumnFamily<?,?> cf)
Drops a column family.
|
void |
EntityManager.executeOperation()
EntityManager.executeOperation() executes a Write Operation. |
<I extends Serializable,K extends Serializable & Comparable<K>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<I,K> cf,
Provider<ColumnDecoder<K,?>,ColumnName<K,?>> decoderProvider,
I id)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
Collection<K> rows,
Collection<ColumnName<C,?>> columns,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
Collection<K> rowKeys,
ColumnName<C,?> startColumn,
ColumnName<C,?> endColumn,
boolean reversed,
int limit,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<I, K>, com.hp.util.Provider<com.hp.util.persistence.cassandra.entitymgr.column.ColumnDecoder<K, ?>, com.hp.util.persistence.cassandra.entitymgr.column.ColumnName<K, ?>>, I) retrieves a collection of specified rows
and a specified range of columns in each row. |
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
Collection<K> rowKeys,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoderProvider)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> cf,
ColumnName<C,?> column,
boolean key,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> cf,
ColumnName<C,?> column,
int key,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> cf,
ColumnName<C,?> column,
String key,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey,
ByteBuffer startColumn,
ByteBuffer endColumn,
boolean reversed,
int limit,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey,
com.netflix.astyanax.model.ByteBufferRange range,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey,
Collection<ColumnName<C,?>> columns,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<I, K>, com.hp.util.Provider<com.hp.util.persistence.cassandra.entitymgr.column.ColumnDecoder<K, ?>, com.hp.util.persistence.cassandra.entitymgr.column.ColumnName<K, ?>>, I) is used for reading a non-contiguous set of
columns from the database. |
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey,
ColumnName<C,?> startColumn,
ColumnName<C,?> endColumn,
boolean reversed,
int limit,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
K rowKey,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder,
ColumnName<C,?>... columnNames)
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<I, K>, com.hp.util.Provider<com.hp.util.persistence.cassandra.entitymgr.column.ColumnDecoder<K, ?>, com.hp.util.persistence.cassandra.entitymgr.column.ColumnName<K, ?>>, I) retrieves a set of non-contiguous columns as
per the user request. |
static void |
EntityManager.truncateColumnFamily(com.netflix.astyanax.model.ColumnFamily<?,?> cf)
Deletes all data from a column family.
|
Constructor and Description |
---|
ConnectionManager(KeySpaceConfig cassandraConfigSetup)
Constructor for creating a Client context for connection with the
database.
|
Copyright © 2015. All Rights Reserved.