RYA-455 stopAll queries for a rya instance
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/9e8a27c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/9e8a27c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/9e8a27c2 Branch: refs/heads/master Commit: 9e8a27c2d73fc6a1fe517f95b21393d85431b1ac Parents: 36af115 Author: Andrew Smith <[email protected]> Authored: Tue Jan 23 15:44:32 2018 -0500 Committer: Valiyil <[email protected]> Committed: Fri Mar 9 12:59:39 2018 -0500 ---------------------------------------------------------------------- .../org/apache/rya/streams/querymanager/QueryExecutor.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/9e8a27c2/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java ---------------------------------------------------------------------- diff --git a/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java b/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java index e888879..4572f08 100644 --- a/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java +++ b/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java @@ -53,6 +53,14 @@ public interface QueryExecutor extends Service { public void stopQuery(final UUID queryID) throws QueryExecutorException; /** + * Stops all {@link StreamsQuery} belonging to a specific rya instance. + * + * @param ryaInstanceName - The name of the rya instance to stop all queries for. (not null) + * @throws QueryExecutorException When the queries fails to stop. + */ + public void stopAll(final String ryaInstanceName) throws QueryExecutorException; + + /** * @return - A set of {@link UUID}s representing the current active queries. * @throws QueryExecutorException Can't discover which queries are currently running. */
