org.apache.fluo.recipes.core.transaction

Class RecordingTransactionBase

java.lang.Object

org.apache.fluo.api.client.AbstractSnapshotBase

org.apache.fluo.api.client.AbstractTransactionBase

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

All Implemented Interfaces:

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

Direct Known Subclasses:

RecordingTransaction

public class RecordingTransactionBase
extends org.apache.fluo.api.client.AbstractTransactionBase
implements org.apache.fluo.api.client.TransactionBase

An implementation of TransactionBase 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	delete(org.apache.fluo.api.data.Bytes row, org.apache.fluo.api.data.Column col)
org.apache.fluo.api.data.Bytes	get(org.apache.fluo.api.data.Bytes row, org.apache.fluo.api.data.Column col) Logs GETs for returned Row/Columns.
Map<org.apache.fluo.api.data.Column,org.apache.fluo.api.data.Bytes>	get(org.apache.fluo.api.data.Bytes row, Set<org.apache.fluo.api.data.Column> columns) Logs GETs for returned Row/Columns.
Map<org.apache.fluo.api.data.Bytes,Map<org.apache.fluo.api.data.Column,org.apache.fluo.api.data.Bytes>>	get(Collection<org.apache.fluo.api.data.Bytes> rows, Set<org.apache.fluo.api.data.Column> columns) Logs GETs for returned Row/Columns.
Map<org.apache.fluo.api.data.RowColumn,org.apache.fluo.api.data.Bytes>	get(Collection<org.apache.fluo.api.data.RowColumn> rowColumns)
long	getStartTimestamp()
TxLog	getTxLog()
org.apache.fluo.api.client.scanner.ScannerBuilder	scanner() Logs GETs for Row/Columns returned by iterators.
void	set(org.apache.fluo.api.data.Bytes row, org.apache.fluo.api.data.Column col, org.apache.fluo.api.data.Bytes value)
void	setWeakNotification(org.apache.fluo.api.data.Bytes row, org.apache.fluo.api.data.Column col)
static RecordingTransactionBase	wrap(org.apache.fluo.api.client.TransactionBase txb) Creates a RecordingTransactionBase by wrapping an existing TransactionBase
static RecordingTransactionBase	wrap(org.apache.fluo.api.client.TransactionBase txb, Predicate<LogEntry> filter) Creates a RecordingTransactionBase using the provided LogEntry filter function and existing TransactionBase

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, set, setWeakNotification, withReadLock

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

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

Method Detail

setWeakNotification

public void setWeakNotification(org.apache.fluo.api.data.Bytes row,
                                org.apache.fluo.api.data.Column col)

Specified by:

setWeakNotification in interface org.apache.fluo.api.client.TransactionBase

set

public void set(org.apache.fluo.api.data.Bytes row,
                org.apache.fluo.api.data.Column col,
                org.apache.fluo.api.data.Bytes value)
         throws org.apache.fluo.api.exceptions.AlreadySetException

Specified by:

set in interface org.apache.fluo.api.client.TransactionBase

Throws:

org.apache.fluo.api.exceptions.AlreadySetException

delete

public void delete(org.apache.fluo.api.data.Bytes row,
                   org.apache.fluo.api.data.Column col)

Specified by:

delete in interface org.apache.fluo.api.client.TransactionBase

get

public org.apache.fluo.api.data.Bytes get(org.apache.fluo.api.data.Bytes row,
                                          org.apache.fluo.api.data.Column col)

Logs GETs for returned Row/Columns. Requests that return no data will not be logged.

Specified by:

get in interface org.apache.fluo.api.client.SnapshotBase

get

public Map<org.apache.fluo.api.data.Column,org.apache.fluo.api.data.Bytes> get(org.apache.fluo.api.data.Bytes row,
                                                                               Set<org.apache.fluo.api.data.Column> columns)

Logs GETs for returned Row/Columns. Requests that return no data will not be logged.

Specified by:

get in interface org.apache.fluo.api.client.SnapshotBase

get

public Map<org.apache.fluo.api.data.Bytes,Map<org.apache.fluo.api.data.Column,org.apache.fluo.api.data.Bytes>> get(Collection<org.apache.fluo.api.data.Bytes> rows,
                                                                                                                   Set<org.apache.fluo.api.data.Column> columns)

Logs GETs for returned Row/Columns. Requests that return no data will not be logged.

Specified by:

get in interface org.apache.fluo.api.client.SnapshotBase

get

public Map<org.apache.fluo.api.data.RowColumn,org.apache.fluo.api.data.Bytes> get(Collection<org.apache.fluo.api.data.RowColumn> rowColumns)

Specified by:

get in interface org.apache.fluo.api.client.SnapshotBase

scanner

public org.apache.fluo.api.client.scanner.ScannerBuilder scanner()

Logs GETs for Row/Columns returned by iterators. Requests that return no data will not be logged.

Specified by:

scanner in interface org.apache.fluo.api.client.SnapshotBase

getStartTimestamp

public long getStartTimestamp()

Specified by:

getStartTimestamp in interface org.apache.fluo.api.client.SnapshotBase

getTxLog

public TxLog getTxLog()

wrap

public static RecordingTransactionBase wrap(org.apache.fluo.api.client.TransactionBase txb)

Creates a RecordingTransactionBase by wrapping an existing TransactionBase

wrap

public static RecordingTransactionBase wrap(org.apache.fluo.api.client.TransactionBase txb,
                                            Predicate<LogEntry> filter)

Creates a RecordingTransactionBase using the provided LogEntry filter function and existing TransactionBase