Interface ITableRowEventBatch<T>

Namespace

Apache.Ignite.Table

Assembly

Apache.Ignite.dll

Table row event batch.

public interface ITableRowEventBatch<out T>

Type Parameters

T

Event type.

Properties

Events

Gets the events.

IReadOnlyList<ITableRowEvent<out T>> Events { get; }

Property Value

IReadOnlyList<ITableRowEvent<T>>

Methods

GetWatermark()

Gets the batch watermark for resume and failover purposes.

NOTE: For performance reasons (to avoid allocating a watermark instance for every event), this method can only be called within current continuous query iteration.

Pass the value to Watermark in order to resume the query from the current batch (exclusive). This provides an uninterrupted stream of events with exactly-once semantics in case of application restarts, failover on another node, etc.

ContinuousQueryEventWatermark GetWatermark()

Returns

ContinuousQueryEventWatermark

Watermark for this event batch.

Exceptions

InvalidOperationException

When called outside of the current continuous query iteration.