knox-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kmin...@apache.org
Subject git commit: New KnoxShell prototype.
Date Thu, 14 Mar 2013 20:12:35 GMT
Updated Branches:
  refs/heads/master 5731395af -> 9f1eafbe2


New KnoxShell prototype.


Project: http://git-wip-us.apache.org/repos/asf/incubator-knox/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-knox/commit/9f1eafbe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-knox/tree/9f1eafbe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-knox/diff/9f1eafbe

Branch: refs/heads/master
Commit: 9f1eafbe2c08b6c6432a0ff77cf2c06ed19a465a
Parents: 5731395
Author: Kevin Minder <kevin.minder@hortonworks.com>
Authored: Thu Mar 14 16:12:19 2013 -0400
Committer: Kevin Minder <kevin.minder@hortonworks.com>
Committed: Thu Mar 14 16:12:19 2013 -0400

----------------------------------------------------------------------
 gateway-shell/pom.xml                              |  106 +++++++++++++++
 .../hadoop/gateway/shell/AbstractRequest.java      |   43 ++++++
 .../hadoop/gateway/shell/AbstractResponse.java     |   34 +++++
 .../org/apache/hadoop/gateway/shell/Example.groovy |   37 +++++
 .../org/apache/hadoop/gateway/shell/KnoxShell.java |   51 +++++++
 .../apache/hadoop/gateway/shell/hadoop/Hadoop.java |   51 +++++++
 .../org/apache/hadoop/gateway/shell/hdfs/Hdfs.java |   42 ++++++
 .../hadoop/gateway/shell/hdfs/HdfsLsRequest.java   |   41 ++++++
 .../hadoop/gateway/shell/hdfs/HdfsLsResponse.java  |   33 +++++
 .../gateway/shell/hdfs/HdfsMkdirRequest.java       |   46 +++++++
 .../gateway/shell/hdfs/HdfsMkdirResponse.java      |   29 ++++
 .../hadoop/gateway/shell/hdfs/HdfsPutRequest.java  |   57 ++++++++
 .../hadoop/gateway/shell/hdfs/HdfsPutResponse.java |   29 ++++
 .../hadoop/gateway/shell/hdfs/HdfsRmRequest.java   |   50 +++++++
 .../hadoop/gateway/shell/hdfs/HdfsRmResponse.java  |   29 ++++
 .../org/apache/hadoop/gateway/shell/job/Job.java   |   30 ++++
 .../hadoop/gateway/shell/job/JobJavaRequest.java   |   58 ++++++++
 .../hadoop/gateway/shell/job/JobJavaResponse.java  |   44 ++++++
 .../hadoop/gateway/shell/workflow/Workflow.java    |   30 ++++
 .../shell/workflow/WorkflowSubmitRequest.java      |   33 +++++
 .../shell/workflow/WorkflowSubmitResponse.java     |   29 ++++
 pom.xml                                            |    2 +-
 22 files changed, 903 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/pom.xml
----------------------------------------------------------------------
diff --git a/gateway-shell/pom.xml b/gateway-shell/pom.xml
new file mode 100644
index 0000000..8e868e2
--- /dev/null
+++ b/gateway-shell/pom.xml
@@ -0,0 +1,106 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  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.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <!--
+    <parent>
+        <artifactId>gateway</artifactId>
+        <groupId>org.apache.hadoop</groupId>
+        <version>0.2.0-SNAPSHOT</version>
+    </parent>
+    -->
+    <groupId>org.apache.hadoop</groupId>
+    <artifactId>gateway-shell</artifactId>
+    <version>0.2.0-SNAPSHOT</version>
+
+    <profiles>
+        <profile>
+            <id>release</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-shade-plugin</artifactId>
+                        <version>2.0</version>
+                        <configuration>
+                            <transformers>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <manifestEntries>
+                                        <Main-Class>org.apache.hadoop.gateway.shell.KnoxShell</Main-Class>
+                                    </manifestEntries>
+                                </transformer>
+                            </transformers>
+                        </configuration>
+                        <executions>
+                            <execution>
+                                <phase>package</phase>
+                                <goals>
+                                    <goal>shade</goal>
+                                </goals>
+                            </execution>
+                        </executions>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.codehaus.groovy</groupId>
+            <artifactId>groovy-all</artifactId>
+            <version>2.1.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.fusesource.jansi</groupId>
+            <artifactId>jansi</artifactId>
+            <version>1.6</version>
+        </dependency>
+        <dependency>
+            <groupId>jline</groupId>
+            <artifactId>jline</artifactId>
+            <version>1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.jayway.restassured</groupId>
+            <artifactId>rest-assured</artifactId>
+            <version>1.7.2</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.hamcrest</groupId>
+            <artifactId>hamcrest-core</artifactId>
+            <version>1.2.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.11</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractRequest.java
new file mode 100644
index 0000000..429dcf9
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractRequest.java
@@ -0,0 +1,43 @@
+package org.apache.hadoop.gateway.shell;
+
+import com.jayway.restassured.specification.RequestSpecification;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+import static com.jayway.restassured.RestAssured.with;
+
+/**
+ * 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.
+ */
+public abstract class AbstractRequest {
+
+  private Hadoop hadoop;
+  private RequestSpecification request;
+
+  public AbstractRequest( Hadoop hadoop ) {
+    this.hadoop = hadoop;
+    request = with().spec( hadoop.request() );
+  }
+
+  protected Hadoop hadoop() {
+    return hadoop;
+  }
+
+  protected RequestSpecification request() {
+    return request;
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractResponse.java
new file mode 100644
index 0000000..645f8d4
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/AbstractResponse.java
@@ -0,0 +1,34 @@
+package org.apache.hadoop.gateway.shell;
+
+import com.jayway.restassured.response.Response;
+
+/**
+ * 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.
+ */
+public abstract class AbstractResponse {
+
+  private Response response;
+
+  protected AbstractResponse( Response response ) {
+    this.response = response;
+  }
+
+  protected Response response() {
+    return response;
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/Example.groovy
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/Example.groovy b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/Example.groovy
new file mode 100644
index 0000000..6d1b53e
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/Example.groovy
@@ -0,0 +1,37 @@
+package org.apache.hadoop.gateway.shell
+
+import org.apache.hadoop.gateway.shell.hdfs.Hdfs
+import org.apache.hadoop.gateway.shell.job.Job
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop
+
+/**
+ * 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.
+ */
+hadoop = Hadoop.login( "http://localhost:8443/gateway/sample", "mapred", "mapred-password"
)
+println Hdfs.ls(hadoop).dir( "/" ).go().json
+Hdfs.rm(hadoop).file( "/tmp/test" ).recursive().go()
+Hdfs.mkdir(hadoop).dir( "/tmp/test").go()
+Hdfs.put(hadoop).from("LICENSE").to("/tmp/test/input/LICENSE").go()
+Hdfs.put(hadoop).from("hadoop-examples.jar").to("/tmp/test/hadoop-examples.jar").go()
+println Job.java(hadoop) \
+    .jar("/tmp/test/hadoop-examples.jar") \
+    .app("wordcount") \
+    .input("/temp/test/input") \
+    .output("/temp/test/output") \
+    .go().jobId
+
+

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/KnoxShell.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/KnoxShell.java b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/KnoxShell.java
new file mode 100644
index 0000000..3ed96a9
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/KnoxShell.java
@@ -0,0 +1,51 @@
+/**
+ * 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.hadoop.gateway.shell;
+
+import org.codehaus.groovy.tools.shell.AnsiDetector;
+import org.codehaus.groovy.tools.shell.Groovysh;
+import org.codehaus.groovy.tools.shell.IO;
+import org.fusesource.jansi.Ansi;
+import org.fusesource.jansi.AnsiConsole;
+
+public class KnoxShell {
+
+  static {
+    AnsiConsole.systemInstall();
+    Ansi.setDetector( new AnsiDetector() );
+  }
+
+  public static void main( String... args ) {
+    Groovysh shell = new Groovysh();
+    shell.execute( "import org.apache.commons.io.FileUtils" );
+    shell.execute( "import static org.apache.commons.io.FileUtils.*" );
+    shell.execute( "import com.jayway.restassured.RestAssured" );
+    shell.execute( "import static com.jayway.restassured.RestAssured.*" );
+    shell.execute( "import com.jayway.restassured.path.json.JsonPath" );
+    shell.execute( "import static com.jayway.restassured.path.json.JsonPath.*" );
+    shell.execute( "import org.apache.hadoop.gateway.shell.hadoop.Hadoop" );
+    shell.execute( "import org.apache.hadoop.gateway.shell.hdfs.Hdfs" );
+    shell.execute( "import static org.apache.hadoop.gateway.shell.hdfs.Hdfs.*" );
+    shell.execute( "import org.apache.hadoop.gateway.shell.job.Job" );
+    shell.execute( "import static org.apache.hadoop.gateway.shell.job.Job.*" );
+    shell.execute( "import org.apache.hadoop.gateway.shell.workflow.Workflow" );
+    shell.execute( "import static org.apache.hadoop.gateway.shell.workflow.Workflow.*" );
+    shell.run( args );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hadoop/Hadoop.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hadoop/Hadoop.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hadoop/Hadoop.java
new file mode 100644
index 0000000..1214709
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hadoop/Hadoop.java
@@ -0,0 +1,51 @@
+/**
+ * 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.hadoop.gateway.shell.hadoop;
+
+import com.jayway.restassured.RestAssured;
+import com.jayway.restassured.specification.RequestSpecification;
+import com.jayway.restassured.specification.ResponseSpecification;
+
+import static com.jayway.restassured.RestAssured.expect;
+import static com.jayway.restassured.RestAssured.with;
+
+public class Hadoop {
+
+  String username;
+  String password;
+
+  public static Hadoop login( String baseUri, String username, String password ) {
+    RestAssured.baseURI = baseUri;
+    return new Hadoop( username, password );
+  }
+
+  public RequestSpecification request() {
+    return with().log().all().auth().preemptive().basic( username, password );
+    //return with().auth().preemptive().basic( username, password );
+  }
+
+  public ResponseSpecification response() {
+    return expect(); //.log().all();
+  }
+
+  private Hadoop( String username, String password ) {
+    this.username = username;
+    this.password = password;
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/Hdfs.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/Hdfs.java b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/Hdfs.java
new file mode 100644
index 0000000..2b80ed6
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/Hdfs.java
@@ -0,0 +1,42 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class Hdfs {
+
+  static String SERVICE_PATH = "/namenode/api/v1";
+
+  public static HdfsLsRequest ls( Hadoop hadoop ) {
+    return new HdfsLsRequest( hadoop );
+  }
+
+  public static HdfsRmRequest rm( Hadoop hadoop ) {
+    return new HdfsRmRequest( hadoop );
+  }
+
+  public static HdfsPutRequest put( Hadoop hadoop ) {
+    return new HdfsPutRequest( hadoop );
+  }
+
+  public static HdfsMkdirRequest mkdir( Hadoop hadoop ) {
+    return new HdfsMkdirRequest( hadoop );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsRequest.java
new file mode 100644
index 0000000..afc1051
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsRequest.java
@@ -0,0 +1,41 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class HdfsLsRequest extends AbstractRequest {
+
+  String dir;
+
+  HdfsLsRequest( Hadoop hadoop ) {
+    super( hadoop );
+    request().queryParam( "op", "LISTSTATUS" );
+  }
+
+  public HdfsLsRequest dir( String dir ) {
+    this.dir = dir;
+    return this;
+  }
+
+  public HdfsLsResponse go() {
+    return new HdfsLsResponse( request().get( Hdfs.SERVICE_PATH + dir ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsResponse.java
new file mode 100644
index 0000000..eac22d9
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsLsResponse.java
@@ -0,0 +1,33 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+public class HdfsLsResponse extends AbstractResponse {
+
+  HdfsLsResponse( Response response ) {
+    super( response );
+  }
+
+  public String getJson() {
+    return response().asString();
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirRequest.java
new file mode 100644
index 0000000..2267bda
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirRequest.java
@@ -0,0 +1,46 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class HdfsMkdirRequest extends AbstractRequest {
+
+  String dir;
+
+  HdfsMkdirRequest( Hadoop hadoop ) {
+    super( hadoop );
+    request().queryParam( "op", "MKDIRS" );
+  }
+
+  public HdfsMkdirRequest perm( String perm ) {
+    request().queryParam( "permission", perm );
+    return this;
+  }
+
+  public HdfsMkdirRequest dir( String dir ) {
+    this.dir = dir;
+    return this;
+  }
+
+  public HdfsMkdirResponse go() {
+    return new HdfsMkdirResponse( request().put( Hdfs.SERVICE_PATH + dir ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirResponse.java
new file mode 100644
index 0000000..ceb6dbe
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsMkdirResponse.java
@@ -0,0 +1,29 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+public class HdfsMkdirResponse extends AbstractResponse {
+
+  HdfsMkdirResponse( Response response ) {
+    super( response );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutRequest.java
new file mode 100644
index 0000000..fb1238d
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutRequest.java
@@ -0,0 +1,57 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import com.jayway.restassured.response.Response;
+import org.apache.commons.io.FileUtils;
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+import java.io.File;
+import java.io.IOException;
+
+import static com.jayway.restassured.RestAssured.with;
+
+public class HdfsPutRequest extends AbstractRequest {
+
+  String from;
+  String to;
+
+  HdfsPutRequest( Hadoop hadoop ) {
+    super( hadoop );
+  }
+
+  public HdfsPutRequest from( String file ) {
+    this.from = file;
+    return this;
+  }
+
+  public HdfsPutRequest to( String file ) {
+    this.to = file;
+    return this;
+  }
+
+  public HdfsPutResponse go() throws IOException {
+    Response response = with().spec( hadoop().request() ).queryParam( "op", "CREATE" )
+        .expect().statusCode( 307 ).when().put( Hdfs.SERVICE_PATH + to );
+    String url = response.getHeader( "Location" );
+    request().body( FileUtils.readFileToByteArray( new File( from ) ) );
+    return new HdfsPutResponse( request().put( url ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutResponse.java
new file mode 100644
index 0000000..828d2b8
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsPutResponse.java
@@ -0,0 +1,29 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+public class HdfsPutResponse extends AbstractResponse {
+
+  HdfsPutResponse( Response response ) {
+    super( response );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmRequest.java
new file mode 100644
index 0000000..8d88bea
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmRequest.java
@@ -0,0 +1,50 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class HdfsRmRequest extends AbstractRequest {
+
+  String file;
+
+  HdfsRmRequest( Hadoop hadoop ) {
+    super( hadoop );
+    request().queryParam( "op", "DELETE" );
+  }
+
+  public HdfsRmRequest file( String file ) {
+    this.file = file;
+    return this;
+  }
+
+  public HdfsRmRequest recursive( boolean recursive ) {
+    request().queryParam( "recursive", Boolean.toString( recursive ) );
+    return this;
+  }
+
+  public HdfsRmRequest recursive() {
+    return recursive( true );
+  }
+
+  public HdfsRmResponse go() {
+    return new HdfsRmResponse( request().delete( Hdfs.SERVICE_PATH + file ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmResponse.java
new file mode 100644
index 0000000..e80f8b0
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/hdfs/HdfsRmResponse.java
@@ -0,0 +1,29 @@
+/**
+ * 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.hadoop.gateway.shell.hdfs;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+public class HdfsRmResponse extends AbstractResponse {
+
+  HdfsRmResponse( Response response ) {
+    super( response );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/Job.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/Job.java b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/Job.java
new file mode 100644
index 0000000..0684a43
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/Job.java
@@ -0,0 +1,30 @@
+/**
+ * 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.hadoop.gateway.shell.job;
+
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class Job {
+
+  static String SERVICE_PATH = "/templeton/api/v1";
+
+  public static JobJavaRequest java( Hadoop hadoop ) {
+    return new JobJavaRequest( hadoop );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaRequest.java
new file mode 100644
index 0000000..14a8838
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaRequest.java
@@ -0,0 +1,58 @@
+/**
+ * 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.hadoop.gateway.shell.job;
+
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class JobJavaRequest extends AbstractRequest {
+
+  String input;
+  String output;
+
+  public JobJavaRequest( Hadoop hadoop ) {
+    super( hadoop );
+  }
+
+  public JobJavaRequest jar( String jar ) {
+    request().formParam( "jar", jar );
+    return this;
+  }
+
+  public JobJavaRequest app( String app ) {
+    request().formParam( "class", app );
+    return this;
+  }
+
+  public JobJavaRequest input( String dir ) {
+    input = dir;
+    return this;
+  }
+
+  public JobJavaRequest output( String dir ) {
+    output = dir;
+    return this;
+  }
+
+  public JobJavaResponse go() {
+    request().formParam( "arg", input );
+    request().formParam( "arg", output );
+    return new JobJavaResponse( request().post( Job.SERVICE_PATH + "/mapreduce/jar" ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaResponse.java
new file mode 100644
index 0000000..65a3166
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/job/JobJavaResponse.java
@@ -0,0 +1,44 @@
+/**
+ * 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.hadoop.gateway.shell.job;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+import static com.jayway.restassured.path.json.JsonPath.from;
+
+public class JobJavaResponse extends AbstractResponse {
+
+  String json = null;
+
+  public JobJavaResponse( Response response ) {
+    super( response );
+  }
+
+  public String getJson() {
+    if( json == null ) {
+      json = response().asString();
+    }
+    return json;
+  }
+
+  public String getJobId() {
+    return from( getJson() ).getString( "id" );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/Workflow.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/Workflow.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/Workflow.java
new file mode 100644
index 0000000..0be9304
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/Workflow.java
@@ -0,0 +1,30 @@
+/**
+ * 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.hadoop.gateway.shell.workflow;
+
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+public class Workflow {
+
+  static String SERVICE_PATH = "oozie";
+
+  public static WorkflowSubmitRequest submit( Hadoop hadoop ) {
+    return new WorkflowSubmitRequest( hadoop );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitRequest.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitRequest.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitRequest.java
new file mode 100644
index 0000000..62aab83
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitRequest.java
@@ -0,0 +1,33 @@
+/**
+ * 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.hadoop.gateway.shell.workflow;
+
+import org.apache.hadoop.gateway.shell.AbstractRequest;
+import org.apache.hadoop.gateway.shell.hadoop.Hadoop;
+
+class WorkflowSubmitRequest extends AbstractRequest {
+
+  WorkflowSubmitRequest( Hadoop hadoop ) {
+    super( hadoop );
+  }
+
+  public WorkflowSubmitResponse go() {
+    return new WorkflowSubmitResponse( request().post( Workflow.SERVICE_PATH ) );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitResponse.java
----------------------------------------------------------------------
diff --git a/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitResponse.java
b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitResponse.java
new file mode 100644
index 0000000..5aa78a9
--- /dev/null
+++ b/gateway-shell/src/main/java/org/apache/hadoop/gateway/shell/workflow/WorkflowSubmitResponse.java
@@ -0,0 +1,29 @@
+/**
+ * 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.hadoop.gateway.shell.workflow;
+
+import com.jayway.restassured.response.Response;
+import org.apache.hadoop.gateway.shell.AbstractResponse;
+
+class WorkflowSubmitResponse extends AbstractResponse {
+
+  WorkflowSubmitResponse( Response response ) {
+    super( response );
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-knox/blob/9f1eafbe/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 19df1cf..1ccc1a1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,5 +1,4 @@
 <?xml version="1.0" encoding="UTF-8"?>
-
 <!--
   Licensed to the Apache Software Foundation (ASF) under one or more
   contributor license agreements.  See the NOTICE file distributed with
@@ -63,6 +62,7 @@
         <module>gateway-test</module>
         <module>gateway-demo</module>
         <module>gateway-site</module>
+        <!-- <module>gateway-shell</module> -->
     </modules>
 
     <properties>


Mime
View raw message