Query Management¶
|
Waits for the termination of this query, either by |
New in version 2.1.0. |
|
|
Prints the (logical and physical) plans to the console for debugging purpose. |
Returns the unique id of this query that persists across restarts from checkpoint data. |
|
Whether this streaming query is currently active or not. |
|
Returns the most recent |
|
Returns the user-specified name of the query, or null if not specified. |
|
Blocks until all available data in the source has been processed and committed to the sink. |
|
Returns an array of the most recent [[StreamingQueryProgress]] updates for this query. |
|
Returns the unique id of this query that does not persist across restarts. |
|
Returns the current status of the query. |
|
Stop this streaming query. |
|
Returns a list of active queries associated with this SparkSession |
|
|
Register a |
Wait until any of the queries on the associated SparkSession has terminated since the creation of the context, or since |
|
Returns an active query from this |
|
|
Deregister a |
Forget about past terminated queries so that |