GitHub user tdas opened a pull request:
https://github.com/apache/spark/pull/11030
[SPARK-13146][SQL] Management API for continuous queries
### Management API for Continuous Queries
**API for getting status of each query**
- Whether active or not
- Unique name of each query
- Status of the sources and sinks
- Exceptions
**API for managing each query**
- Immediately stop an active query
- Waiting for a query to be terminated, correctly or with error
**API for managing multiple queries**
- Listing all active queries
- Getting an active query by name
- Waiting for any one of the active queries to be terminated
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tdas/spark streaming-df-management-api
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/11030.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #11030
----
commit 40c644405184df899ac66d752c2939a1e78676a6
Author: Tathagata Das <[email protected]>
Date: 2016-01-30T00:00:33Z
Management API with tests and everything
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
