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:49 UTC
[03/22] incubator-rya git commit: Rya 454 added QueryExecutor
interface
Rya 454 added QueryExecutor interface
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/eb07bf6e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/eb07bf6e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/eb07bf6e
Branch: refs/heads/master
Commit: eb07bf6eaaa822a2d4ebff3bd098ae6711f24efc
Parents: d6d6d04
Author: Andrew Smith <sm...@gmail.com>
Authored: Fri Jan 19 15:43:55 2018 -0500
Committer: Valiyil <Pu...@parsons.com>
Committed: Fri Mar 9 12:59:35 2018 -0500
----------------------------------------------------------------------
.../rya/streams/querymanager/QueryExecutor.java | 95 ++++++++++++++++++++
1 file changed, 95 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/eb07bf6e/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
new file mode 100644
index 0000000..e888879
--- /dev/null
+++ b/extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryExecutor.java
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.rya.streams.querymanager;
+
+import java.util.Set;
+import java.util.UUID;
+
+import org.apache.rya.streams.api.entity.StreamsQuery;
+import org.openrdf.model.Statement;
+
+import com.google.common.util.concurrent.Service;
+
+import edu.umd.cs.findbugs.annotations.DefaultAnnotation;
+import edu.umd.cs.findbugs.annotations.NonNull;
+
+/**
+ * Represents the system that is responsible for ensuring active {@link StreamsQuery}s are
+ * being processed.
+ */
+@DefaultAnnotation(NonNull.class)
+public interface QueryExecutor extends Service {
+ /**
+ * Starts running a {@link StreamsQuery}.
+ *
+ * @param ryaInstanceName - The rya instance whose {@link Statement}s will be processed by the query. (not null)
+ * @param query - The query to run. (not null)
+ * @throws QueryExecutorException When the query fails to start.
+ */
+ public void startQuery(final String ryaInstanceName, final StreamsQuery query) throws QueryExecutorException;
+
+ /**
+ * Stops a {@link StreamsQuery}.
+ *
+ * @param queryID - The ID of the query to stop. (not null)
+ * @throws QueryExecutorException When the query fails to stop.
+ */
+ public void stopQuery(final UUID queryID) throws QueryExecutorException;
+
+ /**
+ * @return - A set of {@link UUID}s representing the current active queries.
+ * @throws QueryExecutorException Can't discover which queries are currently running.
+ */
+ public Set<UUID> getRunningQueryIds() throws QueryExecutorException;
+
+ /**
+ * Exception to be used by {@link QueryExecutor} when queries fail to start or stop.
+ */
+ public class QueryExecutorException extends Exception {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * Creates a new {@link QueryExecutorException}.
+ *
+ * @param message - The exception message.
+ * @param cause - The cause of this exception.
+ */
+ public QueryExecutorException(final String message, final Throwable cause) {
+ super(message, cause);
+ }
+
+ /**
+ * Creates a new {@link QueryExecutorException}.
+ *
+ * @param message - The exception message.
+ */
+ public QueryExecutorException(final String message) {
+ super(message);
+ }
+
+ /**
+ * Creates a new {@link QueryExecutorException}.
+ *
+ * @param cause - The cause of this exception.
+ */
+ public QueryExecutorException(final Throwable cause) {
+ super(cause);
+ }
+ }
+}