spark技术分享StreamingQuery
StreamingQuery is the contract for a streaming query that is executed continuously and concurrently (i.e. on a separate thread).
|
Note
|
StreamingQuery is called continuous query or streaming query.
|
|
Note
|
StreamingQuery is a Scala trait with the only implementation being StreamExecution (and less importanly StreamingQueryWrapper for serializing a non-serializable StreamExecution).
|
StreamingQuery can be in two states:
-
active (started)
-
inactive (stopped)
If inactive, StreamingQuery may have transitioned into the state due to an StreamingQueryException (that is available under exception).
StreamingQuery tracks current state of all the sources, i.e. SourceStatus, as sourceStatuses.
StreamingQuery can be stopped by stop or an exception.
| Method | Description | ||
|---|---|---|---|
|
|
Used when…FIXME |
||
|
|
Used when…FIXME |
||
|
|
Used when…FIXME |
||
|
|
The unique identifier of the streaming query Used when…FIXME |
||
|
|
Used when…FIXME |
||
|
|
The last StreamingQueryProgress of the streaming query Used when…FIXME |
||
|
|
The name of the query that is unique across all active queries Used when…FIXME |
||
|
|
Waits the streaming query until there are no data available in sources or the query has been terminated. Used when…FIXME |
||
|
|
Collection of the recent StreamingQueryProgress updates. Used when…FIXME |
||
|
|
The unique identifier of the current execution of the streaming query Used when…FIXME |
||
|
|
Used when…FIXME |
||
|
|
The Used when…FIXME |
||
|
|
Stops the streaming query Used exclusively when |
