|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object me.prettyprint.cassandra.model.MutatorImpl<K>
public final class MutatorImpl<K>
A Mutator inserts or deletes values from the cluster. There are two main ways to use a mutator: 1. Use the insert/delete methods to immediately insert of delete values. or 2. Use the addInsertion/addDeletion methods to schedule batch operations and then execute() all of them in batch. The class is not thread-safe.
Field Summary | |
---|---|
protected Serializer<K> |
keySerializer
|
Constructor Summary | |
---|---|
MutatorImpl(Keyspace keyspace)
|
|
MutatorImpl(Keyspace keyspace,
BatchSizeHint sizeHint)
|
|
MutatorImpl(Keyspace keyspace,
Serializer<K> keySerializer)
|
|
MutatorImpl(Keyspace keyspace,
Serializer<K> keySerializer,
BatchSizeHint sizeHint)
|
Method Summary | ||
---|---|---|
|
addCounter(K key,
String cf,
HCounterColumn<N> c)
Schedule an increment of a CounterColumn to be inserted in batch mode by Mutator.execute() |
|
|
addCounter(K key,
String cf,
HCounterSuperColumn<SN,N> sc)
Schedule an increment of a SuperColumn to be inserted in batch mode by Mutator.execute() |
|
|
addCounterDeletion(K key,
String cf)
Alternate form for easy deletion of the whole row. |
|
|
addCounterDeletion(K key,
String cf,
N counterColumnName,
Serializer<N> nameSerializer)
Adds a Deletion to the underlying batch_mutate call. |
|
|
addCounterSubDeletion(K key,
String cf,
HCounterSuperColumn<SN,N> sc)
Schedule a counter deletion. |
|
|
addDeletion(Iterable<K> keys,
String cf)
Convenience methods to delete a list of rows. |
|
|
addDeletion(Iterable<K> keys,
String cf,
long clock)
Convenience methods to delete a list of rows. |
|
|
addDeletion(K key,
String cf)
Alternate form for easy deletion of the whole row. |
|
|
addDeletion(K key,
String cf,
long clock)
Same as above accept we add the clock |
|
|
addDeletion(K key,
String cf,
N columnName,
Serializer<N> nameSerializer)
Adds a Deletion to the underlying batch_mutate call. |
|
|
addDeletion(K key,
String cf,
N columnName,
Serializer<N> nameSerializer,
long clock)
Adds a Deletion to the underlying batch_mutate call. |
|
|
addInsertion(K key,
String cf,
HColumn<N,V> c)
|
|
|
addInsertion(K key,
String cf,
HSuperColumn<SN,N,V> sc)
Schedule an insertion of a supercolumn to be inserted in batch mode by execute() |
|
|
addSubDelete(K key,
String cf,
HSuperColumn<SN,N,V> sc)
Deletes the columns defined in the HSuperColumn. |
|
|
addSubDelete(K key,
String cf,
HSuperColumn<SN,N,V> sc,
long clock)
|
|
|
addSubDelete(K key,
String cf,
SN sColumnName,
N columnName,
Serializer<SN> sNameSerializer,
Serializer<N> nameSerializer)
|
|
|
addSubDelete(K key,
String cf,
SN sColumnName,
N columnName,
Serializer<SN> sNameSerializer,
Serializer<N> nameSerializer,
long clock)
|
|
|
addSuperDelete(K key,
String cf,
SN sColumnName,
Serializer<SN> sNameSerializer)
batches a super column for deletion |
|
|
decrementCounter(K key,
String cf,
N columnName,
long increment)
Convenient method to decrement a simple counter |
|
|
delete(K key,
String cf,
N columnName,
Serializer<N> nameSerializer)
|
|
|
delete(K key,
String cf,
N columnName,
Serializer<N> nameSerializer,
long clock)
|
|
|
deleteCounter(K key,
String cf,
N counterColumnName,
Serializer<N> nameSerializer)
|
|
Mutator<K> |
discardPendingMutations()
Discards all pending mutations. |
|
MutationResult |
execute()
Batch executes all mutations scheduled to this Mutator instance by addInsertion, addDeletion etc. |
|
|
incrementCounter(K key,
String cf,
N columnName,
long increment)
Convenient method to increment a simple counter |
|
|
insert(K key,
String cf,
HColumn<N,V> c)
|
|
|
insert(K key,
String cf,
HSuperColumn<SN,N,V> superColumn)
|
|
|
insertCounter(K key,
String cf,
HCounterColumn<N> c)
Simple and immediate insertion (increment/decrement) of a counter |
|
|
insertCounter(K key,
String cf,
HCounterSuperColumn<SN,N> superColumn)
Simple and immediate insertion (increment/decrement) of a counter part of a super column |
|
|
subDelete(K key,
String cf,
SN supercolumnName,
N columnName,
Serializer<SN> sNameSerializer,
Serializer<N> nameSerializer)
Deletes a subcolumn of a supercolumn |
|
|
subDeleteCounter(K key,
String cf,
SN supercolumnName,
N columnName,
Serializer<SN> sNameSerializer,
Serializer<N> nameSerializer)
Deletes a subcolumn of a supercolumn for a counter |
|
|
superDelete(K key,
String cf,
SN supercolumnName,
Serializer<SN> sNameSerializer)
Deletes a supercolumn immediately |
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected final Serializer<K> keySerializer
Constructor Detail |
---|
public MutatorImpl(Keyspace keyspace, Serializer<K> keySerializer, BatchSizeHint sizeHint)
public MutatorImpl(Keyspace keyspace, Serializer<K> keySerializer)
public MutatorImpl(Keyspace keyspace)
public MutatorImpl(Keyspace keyspace, BatchSizeHint sizeHint)
Method Detail |
---|
public <N,V> MutationResult insert(K key, String cf, HColumn<N,V> c)
insert
in interface Mutator<K>
public <SN,N,V> MutationResult insert(K key, String cf, HSuperColumn<SN,N,V> superColumn)
insert
in interface Mutator<K>
public <N> MutationResult delete(K key, String cf, N columnName, Serializer<N> nameSerializer)
delete
in interface Mutator<K>
public <N> MutationResult delete(K key, String cf, N columnName, Serializer<N> nameSerializer, long clock)
delete
in interface Mutator<K>
public <SN,N> MutationResult subDelete(K key, String cf, SN supercolumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer)
subDelete
in interface Mutator<K>
SN
- super column typeN
- subcolumn typepublic <SN> MutationResult superDelete(K key, String cf, SN supercolumnName, Serializer<SN> sNameSerializer)
Mutator
superDelete
in interface Mutator<K>
SN
- super column typepublic <SN,N,V> Mutator<K> addSubDelete(K key, String cf, HSuperColumn<SN,N,V> sc)
addSubDelete
in interface Mutator<K>
public <SN,N,V> Mutator<K> addSubDelete(K key, String cf, HSuperColumn<SN,N,V> sc, long clock)
addSubDelete
in interface Mutator<K>
public <N,V> Mutator<K> addInsertion(K key, String cf, HColumn<N,V> c)
addInsertion
in interface Mutator<K>
public <SN,N,V> Mutator<K> addInsertion(K key, String cf, HSuperColumn<SN,N,V> sc)
execute()
addInsertion
in interface Mutator<K>
public <N> Mutator<K> addDeletion(K key, String cf, N columnName, Serializer<N> nameSerializer)
addDeletion
in interface Mutator<K>
N
- column name typekey
- row keycf
- column familycolumnName
- column name. Use null to delete the whole row.nameSerializer
- a name serializer
public <N> Mutator<K> addDeletion(K key, String cf)
addDeletion
in interface Mutator<K>
public <N> Mutator<K> addDeletion(K key, String cf, long clock)
addDeletion
in interface Mutator<K>
public <N> Mutator<K> addDeletion(Iterable<K> keys, String cf)
Mutator
addDeletion
in interface Mutator<K>
keys
- list of keys to deletecf
- Column Family name
public <N> Mutator<K> addDeletion(Iterable<K> keys, String cf, long clock)
Mutator
addDeletion
in interface Mutator<K>
keys
- list of keys to deletecf
- Column Family nameclock
- user defined clock
public <N> Mutator<K> addDeletion(K key, String cf, N columnName, Serializer<N> nameSerializer, long clock)
addDeletion
in interface Mutator<K>
N
- column name typekey
- row keycf
- column familycolumnName
- column name. Use null to delete the whole row.nameSerializer
- a name serializerclock
- custom clock to use in the deletion
public MutationResult execute()
execute
in interface Mutator<K>
public Mutator<K> discardPendingMutations()
discardPendingMutations
in interface Mutator<K>
public String toString()
toString
in class Object
public <N> MutationResult insertCounter(K key, String cf, HCounterColumn<N> c)
Mutator
insertCounter
in interface Mutator<K>
public <N> MutationResult incrementCounter(K key, String cf, N columnName, long increment)
Mutator
incrementCounter
in interface Mutator<K>
public <N> MutationResult decrementCounter(K key, String cf, N columnName, long increment)
Mutator
decrementCounter
in interface Mutator<K>
public <SN,N> MutationResult insertCounter(K key, String cf, HCounterSuperColumn<SN,N> superColumn)
Mutator
insertCounter
in interface Mutator<K>
public <N> MutationResult deleteCounter(K key, String cf, N counterColumnName, Serializer<N> nameSerializer)
deleteCounter
in interface Mutator<K>
public <SN,N> MutationResult subDeleteCounter(K key, String cf, SN supercolumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer)
Mutator
subDeleteCounter
in interface Mutator<K>
SN
- super column typeN
- subcolumn typepublic <N> Mutator<K> addCounter(K key, String cf, HCounterColumn<N> c)
Mutator
Mutator.execute()
addCounter
in interface Mutator<K>
public <SN,N> Mutator<K> addCounter(K key, String cf, HCounterSuperColumn<SN,N> sc)
Mutator
Mutator.execute()
addCounter
in interface Mutator<K>
public <N> Mutator<K> addCounterDeletion(K key, String cf, N counterColumnName, Serializer<N> nameSerializer)
Mutator
addCounterDeletion
in interface Mutator<K>
N
- column name typekey
- row keycf
- column familycounterColumnName
- column name. Use null to delete the whole row.nameSerializer
- a name serializer
public <N> Mutator<K> addCounterDeletion(K key, String cf)
Mutator
addCounterDeletion
in interface Mutator<K>
public <SN,N> Mutator<K> addCounterSubDeletion(K key, String cf, HCounterSuperColumn<SN,N> sc)
Mutator
addCounterSubDeletion
in interface Mutator<K>
public <SN,N> Mutator<K> addSubDelete(K key, String cf, SN sColumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer)
addSubDelete
in interface Mutator<K>
public <SN,N> Mutator<K> addSubDelete(K key, String cf, SN sColumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer, long clock)
addSubDelete
in interface Mutator<K>
public <SN> Mutator<K> addSuperDelete(K key, String cf, SN sColumnName, Serializer<SN> sNameSerializer)
Mutator
addSuperDelete
in interface Mutator<K>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |