فهرست منبع

[spark] Stub out interruption support

Erick Tryzelaar 11 سال پیش
والد
کامیت
933d7f3

+ 9 - 0
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/resources/SessionResource.java

@@ -118,4 +118,13 @@ public class SessionResource {
         sessionManager.close(id);
         return Response.noContent().build();
     }
+
+
+    @Path("/{id}/interrupt")
+    @POST
+    @Timed
+    public Response interruptStatement(@PathParam("id") String id) throws SessionManager.SessionNotFound, Session.StatementNotFound {
+        Session session = sessionManager.get(id);
+        session.interrupt();
+    }
 }

+ 2 - 0
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/sessions/Session.java

@@ -43,6 +43,8 @@ public interface Session {
 
     public void close() throws IOException, InterruptedException, TimeoutException;
 
+    void interrupt() throws Exception;
+
     public static class StatementNotFound extends Throwable {
 
     }

+ 6 - 0
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/sessions/SparkSession.java

@@ -157,6 +157,12 @@ public class SparkSession implements Session {
         process.destroy();
     }
 
+    @Override
+    public void interrupt() throws Exception {
+        // FIXME: is there a better way to do this?
+        throw new Exception("not implemented");
+    }
+
     private void touchLastActivity() {
         this.lastActivity = System.currentTimeMillis();
     }