You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rya.apache.org by pu...@apache.org on 2018/03/09 18:20:51 UTC
[05/22] incubator-rya git commit: RYA-455 stopAll queries for a rya
instance
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 <sm...@gmail.com>
Authored: Tue Jan 23 15:44:32 2018 -0500
Committer: Valiyil <Pu...@parsons.com>
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.
*/