Package org.apache.ignite.table

Class ContinuousQueryTransactionWatermark

java.lang.Object

org.apache.ignite.table.ContinuousQueryTransactionWatermark

All Implemented Interfaces:

Serializable, ContinuousQueryWatermark

public class ContinuousQueryTransactionWatermark
extends Object
implements ContinuousQueryWatermark

Continuous query watermark based on a transaction read timestamp.

See more details in ContinuousQueryWatermark.afterTransaction(Transaction).

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
boolean	isAfter()	Indicates whether the watermark is set to start after the transaction's read timestamp.
Transaction	transaction()	Gets the transaction associated with this watermark.

Methods inherited from class java.lang.Object

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

Method Details

transaction

public Transaction transaction()

Gets the transaction associated with this watermark.

Returns:

Transaction.

isAfter

public boolean isAfter()

Indicates whether the watermark is set to start after the transaction's read timestamp.

Returns:

true if the watermark starts after the transaction's read timestamp, false otherwise.