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 |
Modifier and Type | Field and Description |
---|---|
static Transaction |
Transaction.ALL_VISIBLE_LATEST |
protected Transaction |
AbstractTransactionAwareTable.tx |
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.
|
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.
|
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.
|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionAwareHTable.addToOperation(org.apache.hadoop.hbase.client.OperationWithAttributes op,
Transaction tx) |
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. |
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. |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static Transaction |
TxUtils.createDummyTransaction(TransactionVisibilityState txVisibilityState)
Creates a "dummy" transaction based on the given txVisibilityState's state.
|
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.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.