浏览代码

[spark] Reorganize the code

Erick Tryzelaar 11 年之前
父节点
当前提交
4cc3aaefc2

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

@@ -1,5 +1,7 @@
 package com.cloudera.hue.sparker.server;
 
+import com.cloudera.hue.sparker.server.resources.SessionResource;
+import com.cloudera.hue.sparker.server.sessions.SessionManager;
 import com.sun.jersey.core.spi.factory.ResponseBuilderImpl;
 import io.dropwizard.Application;
 import io.dropwizard.setup.Bootstrap;

+ 15 - 1
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/SessionResource.java → apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/resources/SessionResource.java

@@ -1,7 +1,12 @@
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.resources;
 
+import com.cloudera.hue.sparker.server.sessions.Cell;
+import com.cloudera.hue.sparker.server.sessions.ClosedSessionException;
+import com.cloudera.hue.sparker.server.sessions.Session;
+import com.cloudera.hue.sparker.server.sessions.SessionManager;
 import com.codahale.metrics.annotation.Timed;
 import com.sun.jersey.core.spi.factory.ResponseBuilderImpl;
+import org.hibernate.validator.constraints.NotEmpty;
 
 import javax.validation.Valid;
 import javax.ws.rs.*;
@@ -94,4 +99,13 @@ public class SessionResource {
         sessionManager.close(id);
         return Response.noContent().build();
     }
+
+    private class ExecuteStatementRequest {
+        @NotEmpty
+        private String statement;
+
+        public String getStatement() {
+            return statement;
+        }
+    }
 }

+ 1 - 1
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/Cell.java → apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/sessions/Cell.java

@@ -1,4 +1,4 @@
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.sessions;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 

+ 1 - 1
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/ClosedSessionException.java → apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/sessions/ClosedSessionException.java

@@ -1,4 +1,4 @@
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.sessions;
 
 public class ClosedSessionException extends Throwable {
 }

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

@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.sessions;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 

+ 1 - 1
apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/SessionManager.java → apps/spark/java/sparker-server/src/main/java/com/cloudera/hue/sparker/server/sessions/SessionManager.java

@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.sessions;
 
 import java.io.IOException;
 import java.util.Enumeration;

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

@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package com.cloudera.hue.sparker.server;
+package com.cloudera.hue.sparker.server.sessions;
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;