Uses of Class
org.apache.tephra.Transaction

Packages that use Transaction

Package	Description
org.apache.tephra	This package contains implementations of the transaction system v2.
org.apache.tephra.distributed	This package contains standalone server of the transaction system v2.
org.apache.tephra.hbase
org.apache.tephra.hbase.coprocessor
org.apache.tephra.inmemory	This package contains in memory implementation of the transaction system v2.
org.apache.tephra.util

Uses of Transaction in org.apache.tephra

Fields in org.apache.tephra declared as Transaction

Modifier and Type	Field and Description
static Transaction	Transaction.ALL_VISIBLE_LATEST
protected Transaction	AbstractTransactionAwareTable.tx

Methods in org.apache.tephra that return Transaction

Modifier and Type	Method and Description
Transaction	TransactionSystemClient.checkpoint(Transaction tx) Performs a checkpoint operation on the current transaction, returning a new Transaction instance with the updated state.
Transaction	TransactionManager.checkpoint(Transaction originalTx)
Transaction	TransactionCodec.decode(byte[] encoded)
Transaction	TransactionContext.getCurrentTransaction() Returns the current transaction or null if no transaction is currently in progress.
Transaction	TransactionSystemClient.startLong() Starts new long transaction.
Transaction	TransactionManager.startLong() Start a long transaction.
Transaction	TransactionManager.startLong(String clientId) Starts a long transaction with a client id.
Transaction	TransactionSystemClient.startShort() Starts new short transaction.
Transaction	TransactionManager.startShort() Start a short transaction with the default timeout.
Transaction	TransactionSystemClient.startShort(int timeout) Starts new short transaction.
Transaction	TransactionManager.startShort(int timeoutInSeconds) Start a short transaction with a given timeout.
Transaction	TransactionManager.startShort(String clientId) Start a short transaction with a client id and default timeout.
Transaction	TransactionManager.startShort(String clientId, int timeoutInSeconds) Start a short transaction with a given timeout.

Methods in org.apache.tephra with parameters of type Transaction

Modifier and Type	Method and Description
void	TransactionSystemClient.abort(Transaction tx) Makes transaction visible.
void	TransactionManager.abort(Transaction tx)
boolean	TransactionSystemClient.canCommit(Transaction tx, Collection<byte[]> changeIds) Checks if transaction with the set of changes can be committed.
boolean	TransactionManager.canCommit(Transaction tx, Collection<byte[]> changeIds)
Transaction	TransactionSystemClient.checkpoint(Transaction tx) Performs a checkpoint operation on the current transaction, returning a new Transaction instance with the updated state.
Transaction	TransactionManager.checkpoint(Transaction originalTx)
boolean	TransactionSystemClient.commit(Transaction tx) Makes transaction visible.
boolean	TransactionManager.commit(Transaction tx)
byte[]	TransactionCodec.encode(Transaction tx)
void	AbstractTransactionAwareTable.startTx(Transaction tx)
void	TransactionAware.startTx(Transaction tx) Called when new transaction has started.
void	AbstractTransactionAwareTable.updateTx(Transaction tx)
void	TransactionAware.updateTx(Transaction tx) Called when the state of the current transaction has been updated.

Constructors in org.apache.tephra with parameters of type Transaction

Constructor and Description
Transaction(Transaction toCopy, long writePointer, long[] checkpointPointers) Creates a new transaction for a checkpoint operation, copying all members from the original transaction, with the updated checkpoint write pointers.

Uses of Transaction in org.apache.tephra.distributed

Methods in org.apache.tephra.distributed that return Transaction

Modifier and Type	Method and Description
Transaction	TransactionServiceThriftClient.checkpoint(Transaction tx)
Transaction	TransactionServiceClient.checkpoint(Transaction tx)
Transaction	TransactionServiceThriftClient.startLong()
Transaction	TransactionServiceClient.startLong()
Transaction	TransactionServiceThriftClient.startLong(String clientId)
Transaction	TransactionServiceThriftClient.startShort()
Transaction	TransactionServiceClient.startShort()
Transaction	TransactionServiceThriftClient.startShort(int timeout)
Transaction	TransactionServiceClient.startShort(int timeout)
Transaction	TransactionServiceThriftClient.startShort(String clientId)
Transaction	TransactionServiceThriftClient.startShort(String clientId, int timeout)
static Transaction	TransactionConverterUtils.unwrap(TTransaction thriftTx)

Methods in org.apache.tephra.distributed with parameters of type Transaction

Modifier and Type	Method and Description
void	TransactionServiceThriftClient.abort(Transaction tx)
void	TransactionServiceClient.abort(Transaction tx)
boolean	TransactionServiceThriftClient.canCommit(Transaction tx, Collection<byte[]> changeIds)
boolean	TransactionServiceClient.canCommit(Transaction tx, Collection<byte[]> changeIds)
Transaction	TransactionServiceThriftClient.checkpoint(Transaction tx)
Transaction	TransactionServiceClient.checkpoint(Transaction tx)
boolean	TransactionServiceThriftClient.commit(Transaction tx)
boolean	TransactionServiceClient.commit(Transaction tx)
static TTransaction	TransactionConverterUtils.wrap(Transaction tx)

Uses of Transaction in org.apache.tephra.hbase

Methods in org.apache.tephra.hbase with parameters of type Transaction

Modifier and Type	Method and Description
void	TransactionAwareHTable.addToOperation(org.apache.hadoop.hbase.client.OperationWithAttributes op, Transaction tx)

Uses of Transaction in org.apache.tephra.hbase.coprocessor

Methods in org.apache.tephra.hbase.coprocessor with parameters of type Transaction

Modifier and Type	Method and Description
protected void	TransactionProcessor.ensureValidTxLifetime(org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment env, org.apache.hadoop.hbase.client.OperationWithAttributes op, Transaction tx) Make sure that the transaction is within the max valid transaction lifetime.
protected org.apache.hadoop.hbase.filter.Filter	TransactionProcessor.getTransactionFilter(Transaction tx, org.apache.hadoop.hbase.regionserver.ScanType type, org.apache.hadoop.hbase.filter.Filter filter) Derived classes can override this method to customize the filter used to return data visible for the current transaction.
static org.apache.hadoop.hbase.filter.Filter	TransactionFilters.getVisibilityFilter(Transaction tx, Map<byte[],Long> ttlByFamily, boolean allowEmptyValues, org.apache.hadoop.hbase.regionserver.ScanType scanType) Creates a new Filter for returning data only from visible transactions.
static org.apache.hadoop.hbase.filter.Filter	TransactionFilters.getVisibilityFilter(Transaction tx, Map<byte[],Long> ttlByFamily, boolean allowEmptyValues, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.filter.Filter cellFilter) Creates a new Filter for returning data only from visible transactions.

Constructors in org.apache.tephra.hbase.coprocessor with parameters of type Transaction

Constructor and Description
TransactionVisibilityFilter(Transaction tx, Map<byte[],Long> ttlByFamily, boolean allowEmptyValues, org.apache.hadoop.hbase.regionserver.ScanType scanType) Creates a new Filter for returning data only from visible transactions.
TransactionVisibilityFilter(Transaction tx, Map<byte[],Long> ttlByFamily, boolean allowEmptyValues, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.filter.Filter cellFilter) Creates a new Filter for returning data only from visible transactions.

Uses of Transaction in org.apache.tephra.inmemory

Methods in org.apache.tephra.inmemory that return Transaction

Modifier and Type	Method and Description
Transaction	MinimalTxSystemClient.checkpoint(Transaction tx)
Transaction	InMemoryTxSystemClient.checkpoint(Transaction tx)
Transaction	DetachedTxSystemClient.checkpoint(Transaction tx)
Transaction	MinimalTxSystemClient.startLong()
Transaction	InMemoryTxSystemClient.startLong()
Transaction	DetachedTxSystemClient.startLong()
Transaction	MinimalTxSystemClient.startShort()
Transaction	InMemoryTxSystemClient.startShort()
Transaction	DetachedTxSystemClient.startShort()
Transaction	MinimalTxSystemClient.startShort(int timeout)
Transaction	InMemoryTxSystemClient.startShort(int timeout)
Transaction	DetachedTxSystemClient.startShort(int timeout)

Methods in org.apache.tephra.inmemory with parameters of type Transaction

Modifier and Type	Method and Description
void	MinimalTxSystemClient.abort(Transaction tx)
void	InMemoryTxSystemClient.abort(Transaction tx)
void	DetachedTxSystemClient.abort(Transaction tx)
boolean	MinimalTxSystemClient.canCommit(Transaction tx, Collection<byte[]> changeIds)
boolean	InMemoryTxSystemClient.canCommit(Transaction tx, Collection<byte[]> changeIds)
boolean	DetachedTxSystemClient.canCommit(Transaction tx, Collection<byte[]> changeIds)
Transaction	MinimalTxSystemClient.checkpoint(Transaction tx)
Transaction	InMemoryTxSystemClient.checkpoint(Transaction tx)
Transaction	DetachedTxSystemClient.checkpoint(Transaction tx)
boolean	MinimalTxSystemClient.commit(Transaction tx)
boolean	InMemoryTxSystemClient.commit(Transaction tx)
boolean	DetachedTxSystemClient.commit(Transaction tx)

Uses of Transaction in org.apache.tephra.util

Methods in org.apache.tephra.util that return Transaction

Modifier and Type	Method and Description
static Transaction	TxUtils.createDummyTransaction(TransactionVisibilityState txVisibilityState) Creates a "dummy" transaction based on the given txVisibilityState's state.

Methods in org.apache.tephra.util with parameters of type Transaction

Modifier and Type	Method and Description
static long	TxUtils.getMaxVisibleTimestamp(Transaction tx) Returns the maximum timestamp to use for time-range operations, based on the given transaction.
static long	TxUtils.getOldestVisibleTimestamp(Map<byte[],Long> ttlByFamily, Transaction tx) Returns the oldest visible timestamp for the given transaction, based on the TTLs configured for each column family.
static long	TxUtils.getOldestVisibleTimestamp(Map<byte[],Long> ttlByFamily, Transaction tx, boolean readNonTxnData) Returns the oldest visible timestamp for the given transaction, based on the TTLs configured for each column family.
static long	TxUtils.getPruneUpperBound(Transaction tx) Returns the maximum transaction that can be removed from the invalid list for the state represented by the given transaction.