Package org.apache.ignite.table

Interface TableRowEvent<T>

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

  • Method Details

    • type

      TableRowEventType type()
      Gets the event type.
      Returns:
      Event type.

    • entry

      @Nullable T entry()
      Gets the resulting entry value. Null if the event type is TableRowEventType.REMOVED.
      Returns:
      Resulting entry value.

    • oldEntry

      @Nullable T oldEntry()
      Gets the previous entry value. Null if the event type is TableRowEventType.CREATED.
      Returns:
      Previous entry value.

    • watermark

      ContinuousQueryWatermark watermark()
      Gets the event watermark for resume and failover purposes. Pass the value to ContinuousQueryOptions.watermark() in order to resume the query from the current event (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 watermark.