|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object me.prettyprint.cassandra.service.template.AbstractColumnFamilyTemplate<K,SN> me.prettyprint.cassandra.service.template.SuperCfTemplate<K,SN,N>
public abstract class SuperCfTemplate<K,SN,N>
Field Summary | |
---|---|
protected Serializer<N> |
subSerializer
|
Fields inherited from class me.prettyprint.cassandra.service.template.AbstractColumnFamilyTemplate |
---|
activeSlicePredicate, ALL_COLUMNS_COUNT, ALL_COLUMNS_END, ALL_COLUMNS_START, batched, clock, columnFactory, columnFamily, columnParent, columnValueSerializers, exceptionsTranslator, keySerializer, keyspace, topSerializer |
Constructor Summary | |
---|---|
SuperCfTemplate(Keyspace keyspace,
String columnFamily,
Serializer<K> keySerializer,
Serializer<SN> topSerializer,
Serializer<N> subSerializer)
|
Method Summary | ||
---|---|---|
int |
countColumns(K key)
|
|
int |
countColumns(K key,
SN start,
SN end,
int max)
Counts columns in the specified range of a super column family |
|
int |
countSubColumns(K key,
SN superColumnName)
|
|
int |
countSubColumns(K key,
SN superColumnName,
N start,
N end,
int max)
Counts child columns in the specified range of a children in a specified super column |
|
SuperCfUpdater<K,SN,N> |
createUpdater(K key)
|
|
SuperCfUpdater<K,SN,N> |
createUpdater(K key,
SN sColumnName)
|
|
void |
deleteColumn(K key,
SN sColumnName)
Immediately delete the key and superColumn combination |
|
void |
deleteRow(K key)
Immediately delete the row |
|
protected abstract SuperCfResult<K,SN,N> |
doExecuteMultigetSlice(List<K> keys,
HSlicePredicate<SN> predicate)
|
|
protected abstract SuperCfResult<K,SN,N> |
doExecuteSlice(K key,
SN sColumnName,
HSlicePredicate<SN> predicate)
|
|
Serializer<N> |
getSubSerializer()
|
|
boolean |
isColumnsExist(K key)
Checks if there are any columns at a row specified by key in a super column family |
|
boolean |
isSubColumnsExist(K key,
SN superColumnName)
Checks if there are any columns at a row specified by key in a specific super column |
|
|
querySingleSubColumn(K key,
SN columnName,
N subColumnName,
Serializer<V> valueSerializer)
|
|
SuperCfResult<K,SN,N> |
querySuperColumn(K key,
SN sColumnName)
|
|
SuperCfResult<K,SN,N> |
querySuperColumns(K key)
|
|
SuperCfResult<K,SN,N> |
querySuperColumns(K key,
List<SN> sColumnNames)
|
|
|
querySuperColumns(K key,
List<SN> sColumnNames,
SuperCfRowMapper<K,SN,N,T> mapper)
|
|
SuperCfResult<K,SN,N> |
querySuperColumns(List<K> keys)
|
|
SuperCfResult<K,SN,N> |
querySuperColumns(List<K> keys,
List<SN> sColumnNames)
|
|
void |
update(SuperCfUpdater<K,SN,N> updater)
Calls SuperCfUpdater.updateInternal() and AbstractTemplateUpdater.update()
in that order before invoking AbstractColumnFamilyTemplate.executeIfNotBatched(Mutator) on the underlying
upater's Mutator |
Methods inherited from class me.prettyprint.cassandra.service.template.AbstractColumnFamilyTemplate |
---|
addColumn, createMutator, deleteColumn, deleteRow, executeBatch, executeIfNotBatched, executeIfNotBatched, getClock, getColumnFamily, getEffectiveClock, getKeySerializer, getTopSerializer, getValueSerializer, isBatched, setBatched, setClock, setColumnFactory, setCount, setExceptionsTranslator |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Serializer<N> subSerializer
Constructor Detail |
---|
public SuperCfTemplate(Keyspace keyspace, String columnFamily, Serializer<K> keySerializer, Serializer<SN> topSerializer, Serializer<N> subSerializer)
Method Detail |
---|
public Serializer<N> getSubSerializer()
public boolean isColumnsExist(K key)
key
-
public boolean isSubColumnsExist(K key, SN superColumnName)
key
- superColumnName
- subSerializer
- the column name serializer of the child columns
public int countColumns(K key)
key
-
public int countSubColumns(K key, SN superColumnName)
key
- superColumnName
-
public int countColumns(K key, SN start, SN end, int max)
key
- start
- end
- max
-
public int countSubColumns(K key, SN superColumnName, N start, N end, int max)
SUBCOL
- key
- superColumnName
- start
- end
- max
- subSerializer
-
public <V> HColumn<N,V> querySingleSubColumn(K key, SN columnName, N subColumnName, Serializer<V> valueSerializer)
public SuperCfResult<K,SN,N> querySuperColumns(K key, List<SN> sColumnNames)
public SuperCfResult<K,SN,N> querySuperColumns(List<K> keys, List<SN> sColumnNames)
public SuperCfResult<K,SN,N> querySuperColumns(List<K> keys)
public <T> T querySuperColumns(K key, List<SN> sColumnNames, SuperCfRowMapper<K,SN,N,T> mapper)
public SuperCfResult<K,SN,N> querySuperColumns(K key)
public SuperCfResult<K,SN,N> querySuperColumn(K key, SN sColumnName)
public SuperCfUpdater<K,SN,N> createUpdater(K key, SN sColumnName)
public SuperCfUpdater<K,SN,N> createUpdater(K key)
public void update(SuperCfUpdater<K,SN,N> updater)
SuperCfUpdater.updateInternal()
and AbstractTemplateUpdater.update()
in that order before invoking AbstractColumnFamilyTemplate.executeIfNotBatched(Mutator)
on the underlying
upater's Mutator
updater
- public void deleteColumn(K key, SN sColumnName)
deleteColumn
in class AbstractColumnFamilyTemplate<K,SN>
public void deleteRow(K key)
deleteRow
in class AbstractColumnFamilyTemplate<K,SN>
protected abstract SuperCfResult<K,SN,N> doExecuteSlice(K key, SN sColumnName, HSlicePredicate<SN> predicate)
protected abstract SuperCfResult<K,SN,N> doExecuteMultigetSlice(List<K> keys, HSlicePredicate<SN> predicate)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |