Package org.apache.ignite.client.handler.requests.tx

Class ClientTxPartitionEnlistmentCleaner

java.lang.Object

org.apache.ignite.client.handler.requests.tx.ClientTxPartitionEnlistmentCleaner

public class ClientTxPartitionEnlistmentCleaner
extends Object

Helper class to clean up direct transaction enlistments on the server side for a client connection.

Constructor Summary

Constructors

Constructor	Description
ClientTxPartitionEnlistmentCleaner(UUID txId, org.apache.ignite.internal.tx.TxManager txManager, org.apache.ignite.internal.table.IgniteTablesInternal igniteTables)	Creates a new instance of the transaction partition enlistment cleaner.

Method Summary

Modifier and Type	Method	Description
void	addEnlistment(int tableId, int partId)	Adds a partition enlistment for the given table and partition.
CompletableFuture<Void>	clean(boolean abortTx)	Discards local write intents for all enlisted partitions.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientTxPartitionEnlistmentCleaner

public ClientTxPartitionEnlistmentCleaner(UUID txId,
 org.apache.ignite.internal.tx.TxManager txManager,
 org.apache.ignite.internal.table.IgniteTablesInternal igniteTables)

Creates a new instance of the transaction partition enlistment cleaner.

Parameters:

txId - Transaction ID.

txManager - Transaction manager.

igniteTables - Ignite tables.

Method Details

addEnlistment

public void addEnlistment(int tableId,
 int partId)

Adds a partition enlistment for the given table and partition.

Parameters:

tableId - Table ID.

partId - Partition ID.

clean

public CompletableFuture<Void> clean(boolean abortTx)

Discards local write intents for all enlisted partitions.

Parameters:

abortTx - Whether to abort the transaction as well.

Returns:

Future that completes when cleanup is done.