public class WrappedLifecycleTransaction extends java.lang.Object implements ILifecycleTransaction
Transactional.AbstractTransactional| Constructor and Description |
|---|
WrappedLifecycleTransaction(ILifecycleTransaction delegate) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Throwable |
abort(java.lang.Throwable accumulate) |
void |
checkpoint() |
void |
close() |
java.lang.Throwable |
commit(java.lang.Throwable accumulate) |
SSTableReader |
current(SSTableReader reader) |
boolean |
isObsolete(SSTableReader reader) |
boolean |
isOffline() |
void |
obsolete(SSTableReader reader) |
void |
obsoleteOriginals() |
OperationType |
opType() |
java.util.Set<SSTableReader> |
originals() |
void |
prepareToCommit() |
void |
trackNew(SSTable table)
Called when a new table is about to be created, so that this table can be tracked by a transaction.
|
void |
untrackNew(SSTable table)
Called when a new table is no longer required, so that this table can be untracked by a transaction.
|
void |
update(java.util.Collection<SSTableReader> readers,
boolean original) |
void |
update(SSTableReader reader,
boolean original) |
public WrappedLifecycleTransaction(ILifecycleTransaction delegate)
public void checkpoint()
checkpoint in interface ILifecycleTransactionpublic void update(SSTableReader reader, boolean original)
update in interface ILifecycleTransactionpublic void update(java.util.Collection<SSTableReader> readers, boolean original)
update in interface ILifecycleTransactionpublic SSTableReader current(SSTableReader reader)
current in interface ILifecycleTransactionpublic void obsolete(SSTableReader reader)
obsolete in interface ILifecycleTransactionpublic void obsoleteOriginals()
obsoleteOriginals in interface ILifecycleTransactionpublic java.util.Set<SSTableReader> originals()
originals in interface ILifecycleTransactionpublic boolean isObsolete(SSTableReader reader)
isObsolete in interface ILifecycleTransactionpublic java.lang.Throwable commit(java.lang.Throwable accumulate)
commit in interface Transactionalpublic java.lang.Throwable abort(java.lang.Throwable accumulate)
abort in interface Transactionalpublic void prepareToCommit()
prepareToCommit in interface Transactionalpublic void close()
close in interface java.lang.AutoCloseableclose in interface Transactionalpublic void trackNew(SSTable table)
LifecycleNewTrackertrackNew in interface LifecycleNewTrackertable - - the new table to be trackedpublic void untrackNew(SSTable table)
LifecycleNewTrackeruntrackNew in interface LifecycleNewTrackertable - - the table to be untrackedpublic OperationType opType()
opType in interface LifecycleNewTrackerpublic boolean isOffline()
isOffline in interface ILifecycleTransactionCopyright © 2009-2022 The Apache Software Foundation