Package org.apache.ignite.table

Interface TableRowEventBatch<T>

Type Parameters:
T - Event type.
public interface TableRowEventBatch<T>
Table row event batch.

  • Method Details

    • rows

      List<TableRowEvent<T>> rows()
      Gets the events.
      Returns:
      Events.

    • watermark

      ContinuousQueryWatermark watermark()
      Gets the batch watermark for resume and failover purposes. Pass the value to ContinuousQueryOptions.watermark() in order to resume the query from the current batch (exclusive). This provides uninterrupted stream of events with exactly-once semantics in case of application restarts, failover on another node, etc.

      NOTE: for performance reasons, this property can't be accessed outside of Flow.Subscriber.onNext(T) method.

      Returns:
      Event batch watermark.