Package org.apache.ignite.table

Interface ContinuousQuerySource<T>

Type Parameters:
T - Entry type.
All Known Subinterfaces:
KeyValueView<K,V>, RecordView<R>
public interface ContinuousQuerySource<T>
Represents an object which can be queried continuously.

  • Method Details

    • queryContinuously

      void queryContinuously(Flow.Subscriber<TableRowEventBatch<T>> subscriber, @Nullable @Nullable ContinuousQueryOptions options)
      Starts a continuous query which listens to data events within the underlying table.
      Parameters:
      subscriber - Subscriber.
      options - Options (can be null).

    • queryContinuously

      default void queryContinuously(Flow.Subscriber<TableRowEventBatch<T>> subscriber)
      Starts a continuous query which listens to data events within the underlying table.
      Parameters:
      subscriber - Subscriber.