Interface IContinuousQueryWatermark

Namespace

Apache.Ignite.Table

Assembly

Apache.Ignite.dll

Continuous query watermark. Represents a starting point for a continuous query.

public interface IContinuousQueryWatermark

Methods

AfterTransaction(ITransaction)

Creates a new watermark based on a read-only transaction.

This watermark provides a way to get a consistent view of all the existing data in the table and subscribe to any future updates. It guarantees that we either see a given row state as part of the initial query using the transaction, or as a continuous query event.

public static ContinuousQueryTransactionWatermark AfterTransaction(ITransaction transaction)

Parameters

transaction ITransaction

Transaction.

Returns

ContinuousQueryTransactionWatermark

An instance of IContinuousQueryWatermark based on the transaction.

FromInstant(Instant)

Creates a new watermark based on the specified time (wall clock).

Example - start getting events from 10 minutes ago: FromInstant(Instant.FromDateTimeUtc(DateTime.UtcNow.AddMinutes(-10))).

public static IContinuousQueryWatermark FromInstant(Instant startTime)

Parameters

startTime Instant

Query starting point.

Returns

IContinuousQueryWatermark

An instance of IContinuousQueryWatermark representing the specified time.