org.apache.fluo.recipes.core.transaction

Class RecordingTransaction

java.lang.Object

org.apache.fluo.api.client.AbstractSnapshotBase

org.apache.fluo.api.client.AbstractTransactionBase

org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

org.apache.fluo.recipes.core.transaction.RecordingTransaction

All Implemented Interfaces:

AutoCloseable, org.apache.fluo.api.client.SnapshotBase, org.apache.fluo.api.client.Transaction, org.apache.fluo.api.client.TransactionBase

public class RecordingTransaction
extends RecordingTransactionBase
implements org.apache.fluo.api.client.Transaction

An implementation of Transaction that logs all transactions operations (GET, SET, or DELETE) in a TxLog that can be used for exports

Since:

1.0.0

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
static RecordingTransaction	wrap(org.apache.fluo.api.client.Transaction tx) Creates a RecordingTransaction by wrapping an existing Transaction
static RecordingTransaction	wrap(org.apache.fluo.api.client.Transaction tx, Predicate<LogEntry> filter) Creates a RecordingTransaction using the provided LogEntry filter and existing Transaction

Methods inherited from class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

delete, get, get, get, get, getStartTimestamp, getTxLog, scanner, set, setWeakNotification, wrap, wrap

Methods inherited from class org.apache.fluo.api.client.AbstractTransactionBase

delete, set, setWeakNotification

Methods inherited from class org.apache.fluo.api.client.AbstractSnapshotBase

get, get, get, gets, gets, gets, gets, gets, gets, gets

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.fluo.api.client.TransactionBase

delete, delete, set, set, setWeakNotification, setWeakNotification, withReadLock

Methods inherited from interface org.apache.fluo.api.client.SnapshotBase

get, get, get, get, get, get, get, gets, gets, gets, gets, gets, gets, gets, getStartTimestamp, scanner

Method Detail

commit

public void commit()
            throws org.apache.fluo.api.exceptions.CommitException

Specified by:

commit in interface org.apache.fluo.api.client.Transaction

Throws:

org.apache.fluo.api.exceptions.CommitException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.fluo.api.client.Transaction

wrap

public static RecordingTransaction wrap(org.apache.fluo.api.client.Transaction tx)

Creates a RecordingTransaction by wrapping an existing Transaction

wrap

public static RecordingTransaction wrap(org.apache.fluo.api.client.Transaction tx,
                                        Predicate<LogEntry> filter)

Creates a RecordingTransaction using the provided LogEntry filter and existing Transaction