Package | Description |
---|---|
com.hp.util.persistence.cassandra |
...
|
com.hp.util.persistence.cassandra.entitymgr |
...
|
com.hp.util.persistence.cassandra.entitymgr.column |
...
|
com.hp.util.persistence.cassandra.index |
...
|
Modifier and Type | Field and Description |
---|---|
protected Provider<ColumnDecoder<K,?>,ColumnName<K,?>> |
AbstractBaseDao.columnDecoderProvider |
Modifier and Type | Method and Description |
---|---|
protected abstract ColumnDecoder<K,?> |
AbstractBaseDao.getColumnDecoder(ColumnName<K,?> columnName) |
Modifier and Type | Method and Description |
---|---|
Collection<ColumnName<K,?>> |
ColumnFamilyDefinition.getCfMeta()
Returns Column family Meta.
|
Set<ColumnName<K,?>> |
CassandraStorable.getDeletedColumns()
Gets the columns.
|
Modifier and Type | Method and Description |
---|---|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.delete(com.netflix.astyanax.model.ColumnFamily<K,C> columnFamily,
K rowKey,
ColumnName<C,?> columnName)
Deletes a single column.
|
void |
CassandraStorable.delete(ColumnName<K,?> name)
Deletes a column.
|
<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,
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> 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,
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,
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. |
Column<K,?> |
CassandraStorable.getColumn(ColumnName<K,?> name)
Gets the value of the given column.
|
Modifier and Type | Method and Description |
---|---|
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.deleteColumns(com.netflix.astyanax.model.ColumnFamily<K,C> columnFamily,
K rowKey,
Collection<ColumnName<C,?>> columnsNames)
Deletes a collection of columns.
|
<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> 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,
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,
MarkPageRequest<C> request,
com.netflix.astyanax.serializers.CompositeRangeBuilder 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,
MarkPageRequest<C> request,
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. |
<K extends Serializable,C extends Serializable & Comparable<C>> |
EntityManager.get(com.netflix.astyanax.model.ColumnFamily<K,C> colFamily,
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> decoder)
|
<I extends Serializable,K extends Serializable & Comparable<K>> |
EntityManager.prepareDeleteMutation(com.netflix.astyanax.model.ColumnFamily<I,K> colFamily,
I rowKey,
Collection<ColumnName<K,?>> colNames) |
Constructor and Description |
---|
ColumnFamilyDefinition(com.netflix.astyanax.model.ColumnFamily<I,K> columnFamily,
CassDataTypes keyValidator,
CassDataTypes defaultValidator,
CassDataTypes comparator,
String comment,
Collection<ColumnName<K,?>> cfMeta)
Constructor for ColumnFamilyDefinition.
|
Modifier and Type | Method and Description |
---|---|
ColumnName<K,V> |
Column.getName()
Gets the column's name.
|
static <K extends Serializable & Comparable<K>,V> |
ColumnName.valueOf(K name)
Creates a column name.
|
static <K extends Serializable & Comparable<K>,V> |
ColumnName.valueOf(K name,
CassDataTypes v,
boolean isSecIndex) |
Modifier and Type | Method and Description |
---|---|
int |
ColumnName.compareTo(ColumnName<K,?> other) |
Constructor and Description |
---|
BooleanColumn(ColumnName<K,Boolean> name)
Creates a Boolean column with no value.
|
BooleanColumn(ColumnName<K,Boolean> name,
Boolean value)
Creates a boolean column.
|
ByteArrayColumn(ColumnName<K,byte[]> name)
Creates a byte array column with no value.
|
ByteArrayColumn(ColumnName<K,byte[]> name,
byte[] value)
Creates a byte array column.
|
ByteColumn(ColumnName<K,Byte> name)
Creates a byte column with no value.
|
ByteColumn(ColumnName<K,Byte> name,
Byte value)
Creates a byte column.
|
Column(ColumnName<K,V> name)
Creates a column with no value.
|
Column(ColumnName<K,V> name,
V value)
Creates a column.
|
Column(ColumnName<K,V> name,
V value,
com.netflix.astyanax.Serializer<V> serializer) |
CustomColumn(ColumnName<C,D> name)
Creates a boolean column with no value
|
CustomColumn(ColumnName<C,D> name,
D value,
com.netflix.astyanax.Serializer<D> serializer)
Creates a boolean column.
|
DateColumn(ColumnName<K,Date> name)
Creates a Date column with no value.
|
DateColumn(ColumnName<K,Date> name,
Date value)
Creates a Date column.
|
DoubleColumn(ColumnName<K,Double> name)
Creates a double column with no value.
|
DoubleColumn(ColumnName<K,Double> name,
Double value)
Creates a double column.
|
EnumColumn(ColumnName<K,E> name)
Creates a boolean column with no value.
|
EnumColumn(ColumnName<K,E> name,
E value)
Creates a boolean column.
|
FloatColumn(ColumnName<K,Float> name)
Creates a Float column with no value.
|
FloatColumn(ColumnName<K,Float> name,
Float value)
Creates a Float column.
|
IntegerColumn(ColumnName<K,Integer> name)
Creates an Integer column with no value
|
IntegerColumn(ColumnName<K,Integer> name,
Integer value)
Creates an Integer column.
|
LongColumn(ColumnName<K,Long> name)
Creates a Long column with no value.
|
LongColumn(ColumnName<K,Long> name,
Long value)
Creates a Long column.
|
StringColumn(ColumnName<K,String> name)
Creates a String column with no value.
|
StringColumn(ColumnName<K,String> name,
String value)
Creates a String column.
|
ValuelessColumn(ColumnName<C,Void> name)
Creates a boolean column with no value.
|
Modifier and Type | Method and Description |
---|---|
Provider<ColumnDecoder<C,?>,ColumnName<C,?>> |
GenericCustomSecondaryIndex.getDecoderProvider()
Returns the decoder provided used to read from the secondary index column family.
|
static <C extends Serializable & Comparable<C>> |
SecondaryIndexIntegrator.intersect(Collection<SecondaryIndexIntegrator.SecondaryIndexReader<C>> indexes)
Combines the indexes using
AND operation. |
static <C extends Serializable & Comparable<C>> |
SecondaryIndexIntegrator.merge(Collection<SecondaryIndexIntegrator.SecondaryIndexReader<C>> indexes)
Combines the indexes using
OR operation. |
Modifier and Type | Method and Description |
---|---|
Column<C,D> |
Denormalizer.getColumn(ColumnName<C,D> name,
D value)
Creates an indexed column with denormalized data.
|
<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).
|
Modifier and Type | Method and Description |
---|---|
List<Column<C,?>> |
SecondaryIndexIntegrator.SecondaryIndexReader.read(List<ColumnName<C,?>> indexEntries)
Reads the index entries.
|
Copyright © 2015. All Rights Reserved.