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 Summary

Modifier and Type	Method	Description
void	queryContinuously(Flow.Subscriber<TableRowEventBatch<T>> subscriber, @Nullable ContinuousQueryOptions options)	Starts a continuous query which listens to data events within the underlying table.

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).