|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of MutationBatch in com.netflix.astyanax |
---|
Methods in com.netflix.astyanax that return MutationBatch | |
---|---|
MutationBatch |
MutationBatch.lockCurrentTimestamp()
Force all future mutations to have the same timestamp. |
MutationBatch |
MutationBatch.pinToHost(Host host)
Pin this operation to a specific host |
MutationBatch |
Keyspace.prepareMutationBatch()
Prepare a batch mutation object. |
MutationBatch |
MutationBatch.setConsistencyLevel(ConsistencyLevel consistencyLevel)
Set the consistency level for this mutation |
MutationBatch |
MutationBatch.setTimeout(long timeout)
Deprecated. |
MutationBatch |
MutationBatch.setTimestamp(long timestamp)
Set the timestamp for all subsequent operations on this mutation |
MutationBatch |
MutationBatch.usingWriteAheadLog(WriteAheadLog manager)
Specify a write ahead log implementation to use for this mutation |
MutationBatch |
MutationBatch.withRetryPolicy(RetryPolicy retry)
Set the retry policy to use instead of the one specified in the configuration |
Methods in com.netflix.astyanax with parameters of type MutationBatch | |
---|---|
void |
MutationBatch.mergeShallow(MutationBatch other)
Perform a shallow merge of mutations from another batch. |
void |
WriteAheadEntry.readMutation(MutationBatch mutation)
Fill a MutationBatch from the data in this entry |
void |
WriteAheadEntry.writeMutation(MutationBatch mutation)
Write the contents of this mutation to the WAL entry. |
Uses of MutationBatch in com.netflix.astyanax.impl |
---|
Methods in com.netflix.astyanax.impl that return MutationBatch | |
---|---|
MutationBatch |
AckingQueue.getNextMutation(long timeout,
TimeUnit units)
Get the next item from the queue |
Methods in com.netflix.astyanax.impl with parameters of type MutationBatch | |
---|---|
void |
AckingQueue.ackMutation(MutationBatch m)
Ack a mutation so that it may be removed from the queue |
void |
AckingQueue.pushMutation(MutationBatch m)
Insert an item into the queue |
void |
AckingQueue.repushMutation(MutationBatch m)
Return a mutation that couldn't be retried for it be requeued and retryed later |
Uses of MutationBatch in com.netflix.astyanax.recipes.locks |
---|
Methods in com.netflix.astyanax.recipes.locks with parameters of type MutationBatch | |
---|---|
String |
ColumnPrefixDistributedRowLock.fillLockMutation(MutationBatch m,
Long time,
Integer ttl)
Fill a mutation with the lock column. |
void |
ColumnPrefixDistributedRowLock.fillReleaseMutation(MutationBatch m,
boolean excludeCurrentLock)
Fill a mutation that will release the locks. |
void |
ColumnPrefixDistributedRowLock.releaseWithMutation(MutationBatch m)
Release using the provided mutation. |
Uses of MutationBatch in com.netflix.astyanax.recipes.uniqueness |
---|
Methods in com.netflix.astyanax.recipes.uniqueness with parameters of type MutationBatch | |
---|---|
void |
UniquenessConstraint.acquireAndMutate(MutationBatch mutation)
Acquire the uniqueness constraint and apply the final mutation if the row if found to be unique |
void |
RowUniquenessConstraint.acquireAndMutate(MutationBatch mutation)
|
void |
MultiRowUniquenessConstraint.acquireAndMutate(MutationBatch mutation)
|
void |
ColumnPrefixUniquenessConstraint.acquireAndMutate(MutationBatch m)
|
Uses of MutationBatch in com.netflix.astyanax.thrift |
---|
Classes in com.netflix.astyanax.thrift that implement MutationBatch | |
---|---|
class |
AbstractThriftMutationBatchImpl
Basic implementation of a mutation batch using the thrift data structures. |
Methods in com.netflix.astyanax.thrift that return MutationBatch | |
---|---|
MutationBatch |
AbstractThriftMutationBatchImpl.lockCurrentTimestamp()
|
MutationBatch |
ThriftKeyspaceImpl.prepareMutationBatch()
|
MutationBatch |
AbstractThriftMutationBatchImpl.setTimeout(long timeout)
|
MutationBatch |
AbstractThriftMutationBatchImpl.setTimestamp(long timestamp)
|
Methods in com.netflix.astyanax.thrift with parameters of type MutationBatch | |
---|---|
void |
AbstractThriftMutationBatchImpl.mergeShallow(MutationBatch other)
|
Uses of MutationBatch in com.netflix.astyanax.util |
---|
Methods in com.netflix.astyanax.util that return MutationBatch | |
---|---|
MutationBatch |
BlockingAckingQueue.getNextMutation(long timeout,
TimeUnit unit)
|
Methods in com.netflix.astyanax.util with parameters of type MutationBatch | |
---|---|
void |
BlockingAckingQueue.ackMutation(MutationBatch m)
|
com.google.common.util.concurrent.ListenableFuture<OperationResult<Void>> |
WriteAheadMutationBatchExecutor.execute(MutationBatch m)
Write a mutation to the wal and execute it |
void |
MutationBatchExecutorWithQueue.execute(MutationBatch m)
|
void |
BlockingAckingQueue.pushMutation(MutationBatch m)
|
void |
BlockingAckingQueue.repushMutation(MutationBatch m)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |