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

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.