Package org.apache.ignite.internal.processors.cache.transactions

Class IgniteTransactionsImpl<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.transactions.IgniteTransactionsImpl<K,V>

All Implemented Interfaces:

IgniteTransactions, IgniteTransactionsEx

public class IgniteTransactionsImpl<K,V>
extends Object
implements IgniteTransactionsEx

Grid transactions implementation.

Constructor Summary

Constructors

Constructor	Description
IgniteTransactionsImpl(GridCacheSharedContext<K,V> cctx, @Nullable String lb, boolean tracingEnabled)

Method Summary

Modifier and Type	Method	Description
Collection<Transaction>	localActiveTransactions()	Returns a list of active transactions initiated by this node.
TransactionMetrics	metrics()
void	resetMetrics()	Resets transaction metrics.
@Nullable Transaction	tx()	Gets transaction started by this thread or null if this thread does not have a transaction.
Transaction	txStart()	Starts transaction with default isolation, concurrency, timeout, and invalidation policy.
Transaction	txStart(TransactionConcurrency concurrency, TransactionIsolation isolation)	Starts new transaction with the specified concurrency and isolation.
Transaction	txStart(TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)	Starts transaction with specified isolation, concurrency, timeout, invalidation flag, and number of participating entries.
GridNearTxLocal	txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation)
GridNearTxLocal	txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)
IgniteTransactions	withLabel(String lb)	Returns instance of Ignite Transactions to mark a transaction with a special label.
IgniteTransactions	withTracing()	Returns an instance of IgniteTransactions tran will trace every transaction.

Methods inherited from class java.lang.Object

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

Constructor Detail

IgniteTransactionsImpl

public IgniteTransactionsImpl(GridCacheSharedContext<K,V> cctx,
                              @Nullable
                              @Nullable String lb,
                              boolean tracingEnabled)

Parameters:

cctx - Cache shared context.

lb - Label.

Method Detail

txStart

public Transaction txStart()
                    throws IllegalStateException

Starts transaction with default isolation, concurrency, timeout, and invalidation policy. All defaults are set in TransactionConfiguration at startup.

Specified by:

txStart in interface IgniteTransactions

Returns:

New transaction

Throws:

IllegalStateException - If transaction is already started by this thread.

txStart

public Transaction txStart(TransactionConcurrency concurrency,
                           TransactionIsolation isolation)

Starts new transaction with the specified concurrency and isolation.

Specified by:

txStart in interface IgniteTransactions

Parameters:

concurrency - Concurrency.

isolation - Isolation.

Returns:

New transaction.

txStart

public Transaction txStart(TransactionConcurrency concurrency,
                           TransactionIsolation isolation,
                           long timeout,
                           int txSize)

Starts transaction with specified isolation, concurrency, timeout, invalidation flag, and number of participating entries.

Specified by:

txStart in interface IgniteTransactions

Parameters:

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

txSize - Number of entries participating in transaction (may be approximate).

Returns:

New transaction.

txStartEx

public GridNearTxLocal txStartEx(GridCacheContext ctx,
                                 TransactionConcurrency concurrency,
                                 TransactionIsolation isolation,
                                 long timeout,
                                 int txSize)

Specified by:

txStartEx in interface IgniteTransactionsEx

Parameters:

ctx - Cache context.

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

txSize - Number of entries participating in transaction (may be approximate).

Returns:

New transaction.

txStartEx

public GridNearTxLocal txStartEx(GridCacheContext ctx,
                                 TransactionConcurrency concurrency,
                                 TransactionIsolation isolation)

Specified by:

txStartEx in interface IgniteTransactionsEx

Parameters:

ctx - Cache context.

concurrency - Concurrency.

isolation - Isolation.

Returns:

New transaction.

tx

@Nullable
public @Nullable Transaction tx()

Gets transaction started by this thread or null if this thread does not have a transaction.

Specified by:

tx in interface IgniteTransactions

Returns:

Transaction started by this thread or null if this thread does not have a transaction.

metrics

public TransactionMetrics metrics()

Specified by:

metrics in interface IgniteTransactions

Returns:

Transaction metrics.

resetMetrics

public void resetMetrics()

Resets transaction metrics.

Specified by:

resetMetrics in interface IgniteTransactions

localActiveTransactions

public Collection<Transaction> localActiveTransactions()

Returns a list of active transactions initiated by this node.

Note: returned transaction handle will only support getters, Transaction.close(), Transaction.rollback(), Transaction.rollbackAsync() methods. Trying to invoke other methods will lead to UnsupportedOperationException.

Specified by:

localActiveTransactions in interface IgniteTransactions

Returns:

Transactions started on local node.

withLabel

public IgniteTransactions withLabel(String lb)

Returns instance of Ignite Transactions to mark a transaction with a special label. The label can be obtained via Transaction.label() method.

Specified by:

withLabel in interface IgniteTransactions

Parameters:

lb - label.

Returns:

This for chaining.

See Also:

Transaction.label()

withTracing

public IgniteTransactions withTracing()

Returns an instance of IgniteTransactions tran will trace every transaction.

Specified by:

withTracing in interface IgniteTransactions

Returns:

Trace-enabled transactions intance.