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.QueryProgressEvent
:: Experimental ::
Event representing any progress updates in a query
|
static class |
StreamingQueryListener.QueryStartedEvent
:: Experimental ::
Event representing the start of a query
|
static class |
StreamingQueryListener.QueryTerminatedEvent
:: Experimental ::
Event representing that termination of a query
|
Constructor and Description |
---|
StreamingQueryListener() |
Modifier and Type | Method and Description |
---|---|
abstract void |
onQueryProgress(StreamingQueryListener.QueryProgressEvent event)
Called when there is some status update (ingestion rate updated, etc.)
|
abstract void |
onQueryStarted(StreamingQueryListener.QueryStartedEvent event)
Called when a query is started.
|
abstract void |
onQueryTerminated(StreamingQueryListener.QueryTerminatedEvent event)
Called when a query is stopped, with or without error.
|
public abstract void onQueryStarted(StreamingQueryListener.QueryStartedEvent event)
event
- (undocumented)public abstract void onQueryProgress(StreamingQueryListener.QueryProgressEvent event)
event
- (undocumented)public abstract void onQueryTerminated(StreamingQueryListener.QueryTerminatedEvent event)
event
- (undocumented)