|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Mutator<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.
Method Summary | ||
---|---|---|
|
addCounter(K key,
String cf,
HCounterColumn<N> c)
Schedule an increment of a CounterColumn to be inserted in batch mode by execute() |
|
|
addCounter(K key,
String cf,
HCounterSuperColumn<SN,N> sc)
Schedule an increment of a SuperColumn to be inserted in batch mode by 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)
|
|
|
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> nameSerialer)
|
|
|
addSubDelete(K key,
String cf,
SN sColumnName,
N columnName,
Serializer<SN> sNameSerializer,
Serializer<N> nameSerialer,
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 columnName,
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 |
Method Detail |
---|
<N,V> MutationResult insert(K key, String cf, HColumn<N,V> c)
<SN,N,V> MutationResult insert(K key, String cf, HSuperColumn<SN,N,V> superColumn)
<N> MutationResult delete(K key, String cf, N columnName, Serializer<N> nameSerializer)
<N> MutationResult delete(K key, String cf, N columnName, Serializer<N> nameSerializer, long clock)
<SN,N> MutationResult subDelete(K key, String cf, SN supercolumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer)
SN
- super column typeN
- subcolumn type<SN> MutationResult superDelete(K key, String cf, SN supercolumnName, Serializer<SN> sNameSerializer)
SN
- super column type<SN> Mutator<K> addSuperDelete(K key, String cf, SN sColumnName, Serializer<SN> sNameSerializer)
<N,V> Mutator<K> addInsertion(K key, String cf, HColumn<N,V> c)
<SN,N,V> Mutator<K> addInsertion(K key, String cf, HSuperColumn<SN,N,V> sc)
execute()
<N> Mutator<K> addDeletion(K key, String cf, N columnName, Serializer<N> nameSerializer)
N
- column name typekey
- row keycf
- column familycolumnName
- column name. Use null to delete the whole row.nameSerializer
- a name serializer
<N> Mutator<K> addDeletion(K key, String cf)
N
- key
-
<N> Mutator<K> addDeletion(Iterable<K> keys, String cf)
N
- keys
- list of keys to deletecf
- Column Family name
<N> Mutator<K> addDeletion(Iterable<K> keys, String cf, long clock)
N
- keys
- list of keys to deletecf
- Column Family nameclock
- user defined clock
<N> Mutator<K> addDeletion(K key, String cf, long clock)
N
- key
-
<N> Mutator<K> addDeletion(K key, String cf, N columnName, Serializer<N> nameSerializer, long clock)
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
<SN,N,V> Mutator<K> addSubDelete(K key, String cf, HSuperColumn<SN,N,V> sc)
<SN,N,V> Mutator<K> addSubDelete(K key, String cf, HSuperColumn<SN,N,V> sc, long clock)
<SN,N> Mutator<K> addSubDelete(K key, String cf, SN sColumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerialer)
<SN,N> Mutator<K> addSubDelete(K key, String cf, SN sColumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerialer, long clock)
MutationResult execute()
Mutator<K> discardPendingMutations()
<N> MutationResult insertCounter(K key, String cf, HCounterColumn<N> c)
<SN,N> MutationResult insertCounter(K key, String cf, HCounterSuperColumn<SN,N> superColumn)
<N> MutationResult incrementCounter(K key, String cf, N columnName, long increment)
<N> MutationResult decrementCounter(K key, String cf, N columnName, long increment)
<N> MutationResult deleteCounter(K key, String cf, N columnName, Serializer<N> nameSerializer)
<SN,N> MutationResult subDeleteCounter(K key, String cf, SN supercolumnName, N columnName, Serializer<SN> sNameSerializer, Serializer<N> nameSerializer)
SN
- super column typeN
- subcolumn type<N> Mutator<K> addCounter(K key, String cf, HCounterColumn<N> c)
execute()
<SN,N> Mutator<K> addCounter(K key, String cf, HCounterSuperColumn<SN,N> sc)
execute()
<N> Mutator<K> addCounterDeletion(K key, String cf, N counterColumnName, Serializer<N> nameSerializer)
N
- column name typekey
- row keycf
- column familycounterColumnName
- column name. Use null to delete the whole row.nameSerializer
- a name serializer
<N> Mutator<K> addCounterDeletion(K key, String cf)
N
- key
-
<SN,N> Mutator<K> addCounterSubDeletion(K key, String cf, HCounterSuperColumn<SN,N> sc)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |