public abstract class StreamingQueryListener
extends Object
StreamingQueries
.Modifier and Type | Class and Description |
---|---|
static interface |
StreamingQueryListener.Event
:: Experimental ::
Base type of
StreamingQueryListener events |
static class |
StreamingQueryListener.QueryProgress
:: Experimental ::
Event representing any progress updates in a query
|
static class |
StreamingQueryListener.QueryStarted
:: Experimental ::
Event representing the start of a query
|
static class |
StreamingQueryListener.QueryTerminated
:: Experimental ::
Event representing that termination of a query
|
Constructor and Description |
---|
StreamingQueryListener() |
Modifier and Type | Method and Description |
---|---|
abstract void |
onQueryProgress(StreamingQueryListener.QueryProgress queryProgress)
Called when there is some status update (ingestion rate updated, etc.)
|
abstract void |
onQueryStarted(StreamingQueryListener.QueryStarted queryStarted)
Called when a query is started.
|
abstract void |
onQueryTerminated(StreamingQueryListener.QueryTerminated queryTerminated)
Called when a query is stopped, with or without error.
|
public abstract void onQueryStarted(StreamingQueryListener.QueryStarted queryStarted)
queryStarted
- (undocumented)public abstract void onQueryProgress(StreamingQueryListener.QueryProgress queryProgress)
queryProgress
- (undocumented)public abstract void onQueryTerminated(StreamingQueryListener.QueryTerminated queryTerminated)
queryTerminated
- (undocumented)