Package org.gridgain.internal.dr

Class DrUpdateHandlerImpl

java.lang.Object

org.gridgain.internal.dr.DrUpdateHandlerImpl

All Implemented Interfaces:

DrUpdateHandler

public class DrUpdateHandlerImpl
extends Object
implements DrUpdateHandler

Default DrUpdateHandler implementation.

Constructor Summary

Constructors

Constructor	Description
DrUpdateHandlerImpl(org.apache.ignite.Ignite client, Duration tombstoneTtl)	Constructor.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	applyUpdates(org.apache.ignite.table.QualifiedName tableName, List<DrUpdate> rowUpdates, org.apache.ignite.lang.CancellationToken cancellationToken)	Applies row updates.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.internal.dr.DrUpdateHandler

applyUpdates

Constructor Details

DrUpdateHandlerImpl

public DrUpdateHandlerImpl(org.apache.ignite.Ignite client,
 Duration tombstoneTtl)

Constructor.

Parameters:

client - GG9 client node.

tombstoneTtl - Tombstone time-to-live.

Method Details

applyUpdates

public CompletableFuture<Void> applyUpdates(org.apache.ignite.table.QualifiedName tableName,
 List<DrUpdate> rowUpdates,
 org.apache.ignite.lang.CancellationToken cancellationToken)

Description copied from interface: DrUpdateHandler

Applies row updates.

Specified by:

applyUpdates in interface DrUpdateHandler

Parameters:

tableName - Target table name.

rowUpdates - Updates to apply.

cancellationToken - Signals that the batch is abandoned, because the connection it arrived on is gone. Implementations must stop retrying and complete the returned future promptly, so that the batch is released.

Returns:

Future that will be completed once all updates got processed.