StreamingQueryListener
Defined in: streaming/streaming-query-listener.ts:38
Callback interface for streaming-query lifecycle events. Implement any subset of the callbacks; the bus skips the ones you don’t define.
Remarks
Section titled “Remarks”Callbacks dispatch serially per session, so a slow callback delays the
next event. async callbacks are awaited; queue inside the callback if
you need parallel work.
Spark source: StreamingQueryListener.scala
Methods
Section titled “Methods”onQueryIdle()?
Section titled “onQueryIdle()?”optional onQueryIdle(event): void | Promise<void>;Defined in: streaming/streaming-query-listener.ts:41
Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
event |
QueryIdleEvent |
Returns
Section titled “Returns”void | Promise<void>
onQueryProgress()?
Section titled “onQueryProgress()?”optional onQueryProgress(event): void | Promise<void>;Defined in: streaming/streaming-query-listener.ts:40
Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
event |
StreamingQueryProgress |
Returns
Section titled “Returns”void | Promise<void>
onQueryStarted()?
Section titled “onQueryStarted()?”optional onQueryStarted(event): void | Promise<void>;Defined in: streaming/streaming-query-listener.ts:39
Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
event |
QueryStartedEvent |
Returns
Section titled “Returns”void | Promise<void>
onQueryTerminated()?
Section titled “onQueryTerminated()?”optional onQueryTerminated(event): void | Promise<void>;Defined in: streaming/streaming-query-listener.ts:42
Parameters
Section titled “Parameters”| Parameter | Type |
|---|---|
event |
QueryTerminatedEvent |
Returns
Section titled “Returns”void | Promise<void>