github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-10 02:40:49 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-921. Sqoop2: Create standalone shell package

Browse Source 
(Mengwei Ding via Hari Shreedharan)
This commit is contained in:
Hari Shreedharan 2013-08-06 16:18:58 -07:00
parent ff8e0500ad
commit 21c1207b79
59 changed files with 431 additions and 280 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
client/pom.xml
View File

@ -32,6 +32,11 @@ limitations under the License.
<name>Sqoop Client</name>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-all</artifactId>
@ -41,64 +46,11 @@ limitations under the License.
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-common</artifactId>
</dependency>
<dependency>
<groupId>commons-cli</groupId>
<artifactId>commons-cli</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
<dependency>
<groupId>com.sun.jersey</groupId>
<artifactId>jersey-client</artifactId>
<version>1.11</version>
</dependency>
<dependency>
<groupId>jline</groupId>
<artifactId>jline</artifactId>
<version>0.9.94</version>
</dependency>
<dependency>
<groupId>org.fusesource.jansi</groupId>
<artifactId>jansi</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.codehaus.groovy</groupId>
<artifactId>groovy-all</artifactId>
<version>1.8.5</version>
</dependency>
</dependencies>
<profiles>
<profile>
<id>dist</id>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>copy-dependencies</goal>
</goals>
<configuration>
<outputDirectory>${project.build.directory}/lib</outputDirectory>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</profile>
</profiles>
</project>

48
client/src/main/java/org/apache/sqoop/client/ClientError.java Normal file
View File

@ -0,0 +1,48 @@
/**
* 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.sqoop.client;
import org.apache.sqoop.common.ErrorCode;
public enum ClientError implements ErrorCode {
/** An unknown error has occurred. */
CLIENT_0000("An unknown error has occurred"),
/** There occurred exception on server side **/
CLIENT_0001("Server has returned exception"),
/** Polling time of submission status cannot be negative */
CLIENT_0002("Polling time of submission status cannot be negative"),
;
private final String message;
private ClientError(String message) {
this.message = message;
}
public String getCode() {
return name();
}
public String getMessage() {
return message;
}
}

3
client/src/main/java/org/apache/sqoop/client/SqoopClient.java
View File

@ -17,7 +17,6 @@
*/
package org.apache.sqoop.client;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.request.SqoopRequests;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.json.ConnectorBean;
@ -396,7 +395,7 @@ public MSubmission startSubmission(long jid) {
*/
public MSubmission startSubmission(long jid, SubmissionCallback callback, long pollTime) throws InterruptedException {
if(pollTime <= 0) {
throw new SqoopException(ClientError.CLIENT_0008);
throw new SqoopException(ClientError.CLIENT_0002);
}
boolean first = true;
MSubmission submission = requests.createSubmission(jid).getSubmissions().get(0);

5
client/src/main/java/org/apache/sqoop/client/request/Request.java
View File

@ -25,7 +25,8 @@
import com.sun.jersey.api.client.WebResource;
import com.sun.jersey.api.client.WebResource.Builder;
import com.sun.jersey.api.client.filter.ClientFilter;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.ClientError;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.common.SqoopProtocolConstants;
import org.apache.sqoop.json.ThrowableBean;
@ -99,7 +100,7 @@ public ClientResponse handle(ClientRequest cr) {
JSONObject json = (JSONObject) JSONValue.parse(responseText);
ex.restore(json);
throw new SqoopException(ClientError.CLIENT_0006, ex.getThrowable());
throw new SqoopException(ClientError.CLIENT_0001, ex.getThrowable());
}
}

12
dist/pom.xml vendored
View File

@ -40,7 +40,7 @@ limitations under the License.
</dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-client</artifactId>
<artifactId>sqoop-shell</artifactId>
</dependency>
</dependencies>
@ -167,16 +167,16 @@ limitations under the License.
<copy file="../server/target/sqoop.war"
toDir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/server/webapps"/>
<!-- Build client directory -->
<copy todir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/client/lib">
<fileset dir="../client/target/lib">
<!-- Build shell client directory -->
<copy todir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/shell/lib">
<fileset dir="../shell/target/lib">
<include name="*.jar" />
<exclude name="junit-*.jar" />
<exclude name="mockito-*.jar" />
</fileset>
</copy>
<copy file="../client/target/sqoop-client-${project.version}.jar"
toDir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/client/lib"/>
<copy file="../shell/target/sqoop-shell-${project.version}.jar"
toDir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/shell/lib"/>
<!-- Build "bin" directory -->
<copy todir="target/sqoop-${project.version}-bin-hadoop${hadoop.profile}/bin">

4
dist/src/main/bin/sqoop.sh vendored
View File

@ -51,7 +51,7 @@ cd ${BASEDIR}
echo "Sqoop home directory: ${BASEDIR}"
CATALINA_BIN=${CATALINA_BIN:-server/bin}
CLIENT_LIB=${CLIENT_LIB:-client/lib}
CLIENT_LIB=${CLIENT_LIB:-shell/lib}
setup_catalina_opts() {
# The Java System properties 'sqoop.http.port' and 'sqoop.admin.port' are
@ -107,7 +107,7 @@ case $COMMAND in
if [ -n "${JAVA_HOME}" ] ; then
EXEC_JAVA="${JAVA_HOME}/bin/java"
fi
${EXEC_JAVA} -classpath ${CLASSPATH} org.apache.sqoop.client.shell.SqoopShell $2
${EXEC_JAVA} -classpath ${CLASSPATH} org.apache.sqoop.shell.SqoopShell $2
;;
*)

6
pom.xml
View File

@ -246,6 +246,11 @@ limitations under the License.
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-client</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-shell</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
@ -413,6 +418,7 @@ limitations under the License.
<module>repository</module>
<module>server</module>
<module>client</module>
<module>shell</module>
<module>docs</module>
<module>connector</module>
<module>execution</module>

108
shell/pom.xml Normal file
View File

@ -0,0 +1,108 @@
<?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>
<groupId>org.apache</groupId>
<artifactId>sqoop</artifactId>
<version>2.0.0-SNAPSHOT</version>
</parent>
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-shell</artifactId>
<name>Sqoop Shell</name>
<dependencies>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-all</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-common</artifactId>
</dependency>
<dependency>
<groupId>org.apache.sqoop</groupId>
<artifactId>sqoop-client</artifactId>
</dependency>
<dependency>
<groupId>commons-cli</groupId>
<artifactId>commons-cli</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
<dependency>
<groupId>com.sun.jersey</groupId>
<artifactId>jersey-client</artifactId>
<version>1.11</version>
</dependency>
<dependency>
<groupId>jline</groupId>
<artifactId>jline</artifactId>
<version>0.9.94</version>
</dependency>
<dependency>
<groupId>org.fusesource.jansi</groupId>
<artifactId>jansi</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.codehaus.groovy</groupId>
<artifactId>groovy-all</artifactId>
<version>1.8.5</version>
</dependency>
</dependencies>
<profiles>
<profile>
<id>dist</id>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>copy-dependencies</goal>
</goals>
<configuration>
<outputDirectory>${project.build.directory}/lib</outputDirectory>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</profile>
</profiles>
</project>

10
client/src/main/java/org/apache/sqoop/client/shell/CloneCommand.java → shell/src/main/java/org/apache/sqoop/shell/CloneCommand.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Client side cloning of connection and job objects.
@ -42,7 +42,7 @@ public CloneCommand(Shell shell) {
public Object executeCommand(List args) {
if(!isInteractive()) {
throw new SqoopException(ClientError.CLIENT_0007, "clone");
throw new SqoopException(ShellError.SHELL_0007, "clone");
}
if (args.size() == 0) {

12
client/src/main/java/org/apache/sqoop/client/shell/CloneConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/CloneConnectionFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.model.MPersistableEntity;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
*
@ -56,7 +56,7 @@ public Object executeFunction(CommandLine line) {
try {
cloneConnection(getLong(line, Constants.OPT_XID));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

12
client/src/main/java/org/apache/sqoop/client/shell/CloneJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/CloneJobFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.model.MPersistableEntity;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
*
@ -55,7 +55,7 @@ public Object executeFunction(CommandLine line) {
try {
cloneJob(getLong(line, Constants.OPT_JID));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

10
client/src/main/java/org/apache/sqoop/client/shell/CreateCommand.java → shell/src/main/java/org/apache/sqoop/shell/CreateCommand.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*
@ -42,7 +42,7 @@ public CreateCommand(Shell shell) {
public Object executeCommand(List args) {
if(!isInteractive()) {
throw new SqoopException(ClientError.CLIENT_0007, "create");
throw new SqoopException(ShellError.SHELL_0007, "create");
}
if (args.size() == 0) {

14
client/src/main/java/org/apache/sqoop/client/shell/CreateConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/CreateConnectionFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.FormDisplayer;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.FormDisplayer;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
*
@ -55,7 +55,7 @@ public Object executeFunction(CommandLine line) {
try {
createConnection(getLong(line, Constants.OPT_CID));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

14
client/src/main/java/org/apache/sqoop/client/shell/CreateJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/CreateJobFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.FormDisplayer;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.FormDisplayer;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
* Handles creation of new job objects.
@ -67,7 +67,7 @@ public Object executeFunction(CommandLine line) {
createJob(getLong(line, Constants.OPT_XID),
line.getOptionValue(Constants.OPT_TYPE));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

6
client/src/main/java/org/apache/sqoop/client/shell/DeleteCommand.java → shell/src/main/java/org/apache/sqoop/shell/DeleteCommand.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*

6
client/src/main/java/org/apache/sqoop/client/shell/DeleteConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/DeleteConnectionFunction.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*

6
client/src/main/java/org/apache/sqoop/client/shell/DeleteJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/DeleteJobFunction.java
View File

@ -15,14 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.request.JobRequest;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Handles deletion of a job object.

6
client/src/main/java/org/apache/sqoop/client/shell/DisableCommand.java → shell/src/main/java/org/apache/sqoop/shell/DisableCommand.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*

8
client/src/main/java/org/apache/sqoop/client/shell/DisableConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/DisableConnectionFunction.java
View File

@ -15,15 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.validation.Status;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Handles enabling of a connection object

8
client/src/main/java/org/apache/sqoop/client/shell/DisableJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/DisableJobFunction.java
View File

@ -15,16 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.request.JobRequest;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.validation.Status;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Handles disabling of a job object.

6
client/src/main/java/org/apache/sqoop/client/shell/EnableCommand.java → shell/src/main/java/org/apache/sqoop/shell/EnableCommand.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*

8
client/src/main/java/org/apache/sqoop/client/shell/EnableConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/EnableConnectionFunction.java
View File

@ -15,15 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.validation.Status;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Handles enabling of a connection object

8
client/src/main/java/org/apache/sqoop/client/shell/EnableJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/EnableJobFunction.java
View File

@ -15,16 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.request.JobRequest;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.validation.Status;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Handles disabling of a job object.

10
client/src/main/java/org/apache/sqoop/client/shell/HelpCommand.java → shell/src/main/java/org/apache/sqoop/shell/HelpCommand.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.text.MessageFormat;
import java.util.Iterator;
@ -23,15 +23,15 @@
import java.util.List;
import org.apache.commons.lang.StringUtils;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Command;
import org.codehaus.groovy.tools.shell.CommandSupport;
import org.codehaus.groovy.tools.shell.Shell;
import org.codehaus.groovy.tools.shell.util.SimpleCompletor;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
public class HelpCommand extends CommandSupport {
@ -125,7 +125,7 @@ private void help(String name) {
if (command == null) {
String msg = MessageFormat.format(resource.getString(Constants
.RES_UNRECOGNIZED_CMD), name);
throw new SqoopException(ClientError.CLIENT_0001, msg);
throw new SqoopException(ShellError.SHELL_0001, msg);
}
printlnResource(Constants.RES_HELP_CMD_USAGE, command.getName(), command.getUsage());
println();

6
client/src/main/java/org/apache/sqoop/client/shell/SetCommand.java → shell/src/main/java/org/apache/sqoop/shell/SetCommand.java
View File

@ -15,14 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.List;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
public class SetCommand extends SqoopCommand {

6
client/src/main/java/org/apache/sqoop/client/shell/SetOptionFunction.java → shell/src/main/java/org/apache/sqoop/shell/SetOptionFunction.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*

6
client/src/main/java/org/apache/sqoop/client/shell/SetServerFunction.java → shell/src/main/java/org/apache/sqoop/shell/SetServerFunction.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
@SuppressWarnings("serial")
public class SetServerFunction extends SqoopFunction {

8
client/src/main/java/org/apache/sqoop/client/shell/ShellEnvironment.java → shell/src/main/java/org/apache/sqoop/shell/ShellEnvironment.java
View File

@ -15,12 +15,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.SqoopClient;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.IO;
import java.net.MalformedURLException;
@ -129,7 +129,7 @@ public static void setServerUrl(String ustr){
client.setServerUrl(getServerUrl());
} catch (MalformedURLException ex) {
throw new SqoopException(ClientError.CLIENT_0003, ex);
throw new SqoopException(ShellError.SHELL_0003, ex);
}
}

7
client/src/main/java/org/apache/sqoop/client/shell/ShowCommand.java → shell/src/main/java/org/apache/sqoop/shell/ShowCommand.java
View File

@ -15,13 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.List;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
public class ShowCommand extends SqoopCommand
{

10
client/src/main/java/org/apache/sqoop/client/shell/ShowConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowConnectionFunction.java
View File

@ -15,20 +15,20 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.TableDisplayer;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.TableDisplayer;
import java.text.DateFormat;
import java.util.LinkedList;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormDisplayer.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormDisplayer.*;
/**
*

10
client/src/main/java/org/apache/sqoop/client/shell/ShowConnectorFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowConnectorFunction.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.Collection;
import java.util.LinkedList;
@ -23,12 +23,12 @@
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.TableDisplayer;
import org.apache.sqoop.model.MConnector;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.TableDisplayer;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormDisplayer.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormDisplayer.*;
@SuppressWarnings("serial")
public class ShowConnectorFunction extends SqoopFunction {

8
client/src/main/java/org/apache/sqoop/client/shell/ShowFrameworkFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowFrameworkFunction.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.model.MFramework;
import org.apache.sqoop.shell.core.Constants;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormDisplayer.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormDisplayer.*;
/**
*

10
client/src/main/java/org/apache/sqoop/client/shell/ShowJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowJobFunction.java
View File

@ -15,20 +15,20 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.TableDisplayer;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.TableDisplayer;
import java.text.DateFormat;
import java.util.LinkedList;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.client.utils.FormDisplayer.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormDisplayer.*;
/**
*

6
client/src/main/java/org/apache/sqoop/client/shell/ShowOptionFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowOptionFunction.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Show client internal options

6
client/src/main/java/org/apache/sqoop/client/shell/ShowServerFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowServerFunction.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
@SuppressWarnings("serial")
public class ShowServerFunction extends SqoopFunction {

11
client/src/main/java/org/apache/sqoop/client/shell/ShowSubmissionFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowSubmissionFunction.java
View File

@ -15,20 +15,19 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.LinkedList;
import java.util.List;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.SubmissionDisplayer;
import org.apache.sqoop.client.utils.TableDisplayer;
import org.apache.sqoop.model.MSubmission;
import org.apache.sqoop.submission.SubmissionStatus;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.SubmissionDisplayer;
import org.apache.sqoop.shell.utils.TableDisplayer;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
public class ShowSubmissionFunction extends SqoopFunction {
@SuppressWarnings("static-access")

6
client/src/main/java/org/apache/sqoop/client/shell/ShowVersionFunction.java → shell/src/main/java/org/apache/sqoop/shell/ShowVersionFunction.java
View File

@ -15,18 +15,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.Arrays;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.request.VersionRequest;
import org.apache.sqoop.common.VersionInfo;
import org.apache.sqoop.json.VersionBean;
import org.apache.sqoop.shell.core.Constants;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
@SuppressWarnings("serial")
public class ShowVersionFunction extends SqoopFunction {

6
client/src/main/java/org/apache/sqoop/client/shell/SqoopCommand.java → shell/src/main/java/org/apache/sqoop/shell/SqoopCommand.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import groovy.lang.GroovyShell;
import groovy.lang.MissingPropertyException;
@ -23,8 +23,8 @@
import java.util.*;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.codehaus.groovy.tools.shell.ComplexCommandSupport;
import org.codehaus.groovy.tools.shell.Shell;
@ -144,7 +144,7 @@ protected void resolveVariables(List arg) {
temp.add(scr.run().toString());
}
catch(MissingPropertyException e) {
throw new SqoopException(ClientError.CLIENT_0004, e.getMessage(), e);
throw new SqoopException(ShellError.SHELL_0004, e.getMessage(), e);
}
}
Collections.copy(arg, temp);

8
client/src/main/java/org/apache/sqoop/client/shell/SqoopFunction.java → shell/src/main/java/org/apache/sqoop/shell/SqoopFunction.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.Iterator;
import java.util.List;
@ -26,10 +26,10 @@
import org.apache.commons.cli.HelpFormatter;
import org.apache.commons.cli.Options;
import org.apache.commons.cli.ParseException;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
@SuppressWarnings("serial")
abstract public class SqoopFunction extends Options {
@ -63,7 +63,7 @@ protected CommandLine parseOptions(Options options, int start, List<String> argl
try {
line = parser.parse(options, args);
} catch (ParseException e) {
throw new SqoopException(ClientError.CLIENT_0003, e.getMessage(), e);
throw new SqoopException(ShellError.SHELL_0003, e.getMessage(), e);
}
return line;
}

8
client/src/main/java/org/apache/sqoop/client/shell/SqoopShell.java → shell/src/main/java/org/apache/sqoop/shell/SqoopShell.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.io.BufferedReader;
import java.io.File;
@ -24,15 +24,15 @@
import java.util.HashSet;
import java.util.Iterator;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.ThrowableDisplayer;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.ThrowableDisplayer;
import org.codehaus.groovy.runtime.MethodClosure;
import org.codehaus.groovy.tools.shell.Command;
import org.codehaus.groovy.tools.shell.CommandRegistry;
import org.codehaus.groovy.tools.shell.Groovysh;
import org.codehaus.groovy.tools.shell.IO.Verbosity;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Main entry point to Sqoop client.

6
client/src/main/java/org/apache/sqoop/client/shell/StartCommand.java → shell/src/main/java/org/apache/sqoop/shell/StartCommand.java
View File

@ -15,15 +15,15 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.List;
import org.apache.log4j.Logger;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.printlnResource;
import static org.apache.sqoop.shell.ShellEnvironment.printlnResource;
public class StartCommand extends SqoopCommand {
public static final Logger LOG = Logger.getLogger(StartCommand.class);

16
client/src/main/java/org/apache/sqoop/client/shell/StartJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/StartJobFunction.java
View File

@ -15,21 +15,21 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.client;
import static org.apache.sqoop.client.shell.ShellEnvironment.getPollTimeout;
import static org.apache.sqoop.client.shell.ShellEnvironment.resourceString;
import static org.apache.sqoop.shell.ShellEnvironment.client;
import static org.apache.sqoop.shell.ShellEnvironment.getPollTimeout;
import static org.apache.sqoop.shell.ShellEnvironment.resourceString;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.log4j.Logger;
import org.apache.sqoop.client.SubmissionCallback;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.SubmissionDisplayer;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MSubmission;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.SubmissionDisplayer;
public class StartJobFunction extends SqoopFunction {
public static final Logger LOG = Logger.getLogger(StartJobFunction.class);
@ -72,7 +72,7 @@ public void finished(MSubmission submission) {
try {
client.startSubmission(getLong(line, Constants.OPT_JID), callback, pollTimeout);
} catch (InterruptedException e) {
throw new SqoopException(ClientError.CLIENT_0009, e);
throw new SqoopException(ShellError.SHELL_0008, e);
}
} else if (line.hasOption(Constants.OPT_JID)) {
MSubmission submission = client.startSubmission(getLong(line, Constants.OPT_JID));

6
client/src/main/java/org/apache/sqoop/client/shell/StatusCommand.java → shell/src/main/java/org/apache/sqoop/shell/StatusCommand.java
View File

@ -15,14 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.List;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.printlnResource;
import static org.apache.sqoop.shell.ShellEnvironment.printlnResource;
public class StatusCommand extends SqoopCommand {

10
client/src/main/java/org/apache/sqoop/client/shell/StatusJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/StatusJobFunction.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.client;
import static org.apache.sqoop.client.shell.ShellEnvironment.resourceString;
import static org.apache.sqoop.shell.ShellEnvironment.client;
import static org.apache.sqoop.shell.ShellEnvironment.resourceString;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.SubmissionDisplayer;
import org.apache.sqoop.model.MSubmission;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.SubmissionDisplayer;
import org.apache.sqoop.submission.SubmissionStatus;
public class StatusJobFunction extends SqoopFunction{

6
client/src/main/java/org/apache/sqoop/client/shell/StopCommand.java → shell/src/main/java/org/apache/sqoop/shell/StopCommand.java
View File

@ -15,14 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import java.util.List;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.printlnResource;
import static org.apache.sqoop.shell.ShellEnvironment.printlnResource;
public class StopCommand extends SqoopCommand {

10
client/src/main/java/org/apache/sqoop/client/shell/StopJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/StopJobFunction.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import static org.apache.sqoop.client.shell.ShellEnvironment.client;
import static org.apache.sqoop.client.shell.ShellEnvironment.resourceString;
import static org.apache.sqoop.shell.ShellEnvironment.client;
import static org.apache.sqoop.shell.ShellEnvironment.resourceString;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.SubmissionDisplayer;
import org.apache.sqoop.model.MSubmission;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.SubmissionDisplayer;
public class StopJobFunction extends SqoopFunction {

10
client/src/main/java/org/apache/sqoop/client/shell/UpdateCommand.java → shell/src/main/java/org/apache/sqoop/shell/UpdateCommand.java
View File

@ -15,16 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.codehaus.groovy.tools.shell.Shell;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
*
@ -42,7 +42,7 @@ public UpdateCommand(Shell shell) {
public Object executeCommand(List args) {
if(!isInteractive()) {
throw new SqoopException(ClientError.CLIENT_0007, "update");
throw new SqoopException(ShellError.SHELL_0007, "update");
}
if (args.size() == 0) {

14
client/src/main/java/org/apache/sqoop/client/shell/UpdateConnectionFunction.java → shell/src/main/java/org/apache/sqoop/shell/UpdateConnectionFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.FormDisplayer;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MConnection;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.FormDisplayer;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
*
@ -55,7 +55,7 @@ public Object executeFunction(CommandLine line) {
try {
updateConnection(getLong(line, Constants.OPT_XID));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

14
client/src/main/java/org/apache/sqoop/client/shell/UpdateJobFunction.java → shell/src/main/java/org/apache/sqoop/shell/UpdateJobFunction.java
View File

@ -15,23 +15,23 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.shell;
package org.apache.sqoop.shell;
import jline.ConsoleReader;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.OptionBuilder;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.client.utils.FormDisplayer;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.model.MJob;
import org.apache.sqoop.shell.core.ShellError;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.shell.utils.FormDisplayer;
import org.apache.sqoop.validation.Status;
import java.io.IOException;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.utils.FormFiller.*;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.utils.FormFiller.*;
/**
*
@ -55,7 +55,7 @@ public Object executeFunction(CommandLine line) {
try {
updateJob(getLong(line, Constants.OPT_JID));
} catch (IOException ex) {
throw new SqoopException(ClientError.CLIENT_0005, ex);
throw new SqoopException(ShellError.SHELL_0005, ex);
}
return null;

4
client/src/main/java/org/apache/sqoop/client/core/Constants.java → shell/src/main/java/org/apache/sqoop/shell/core/Constants.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.core;
package org.apache.sqoop.shell.core;
/**
*
@ -23,7 +23,7 @@
public class Constants {
// General string constants
public static final String RESOURCE_NAME = "client-resource";
public static final String RESOURCE_NAME = "shell-resource";
public static final String BOLD_STR_SEQUENCE = "@|bold";
public static final String END_STR_SEQUENCE = "|@";

27
client/src/main/java/org/apache/sqoop/client/core/ClientError.java → shell/src/main/java/org/apache/sqoop/shell/core/ShellError.java
View File

@ -15,47 +15,44 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.core;
package org.apache.sqoop.shell.core;
import org.apache.sqoop.common.ErrorCode;
public enum ClientError implements ErrorCode {
public enum ShellError implements ErrorCode {
/** An unknown error has occurred. */
CLIENT_0000("An unknown error has occurred"),
SHELL_0000("An unknown error has occurred"),
/** The specified command is not recognized. */
CLIENT_0001("The specified command is not recognized"),
SHELL_0001("The specified command is not recognized"),
/** The specified function is not recognized. */
CLIENT_0002("The specified function is not recognized"),
SHELL_0002("The specified function is not recognized"),
/** An error has occurred when parsing options. */
CLIENT_0003("An error has occurred when parsing options"),
SHELL_0003("An error has occurred when parsing options"),
/** Unable to resolve the variables. */
CLIENT_0004("Unable to resolve the variables"),
SHELL_0004("Unable to resolve the variables"),
/** We're not able to get user input */
CLIENT_0005("Can't get user input"),
SHELL_0005("Can't get user input"),
/** There occurred exception on server side **/
CLIENT_0006("Server has returned exception"),
SHELL_0006("Server has returned exception"),
/** Command not compatible with batch mode */
CLIENT_0007("Command not compatible with batch mode"),
/** Polling time of submission status cannot be negative */
CLIENT_0008("Polling time of submission status cannot be negative"),
SHELL_0007("Command not compatible with batch mode"),
/** Job Submission : Cannot sleep */
CLIENT_0009("Cannot sleep"),
SHELL_0008("Cannot sleep"),
;
private final String message;
private ClientError(String message) {
private ShellError(String message) {
this.message = message;
}

6
client/src/main/java/org/apache/sqoop/client/utils/FormDisplayer.java → shell/src/main/java/org/apache/sqoop/shell/utils/FormDisplayer.java
View File

@ -15,10 +15,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.utils;
package org.apache.sqoop.shell.utils;
import org.apache.commons.lang.StringUtils;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.model.MAccountableEntity;
import org.apache.sqoop.model.MBooleanInput;
import org.apache.sqoop.model.MConnection;
@ -32,6 +31,7 @@
import org.apache.sqoop.model.MJobForms;
import org.apache.sqoop.model.MMapInput;
import org.apache.sqoop.model.MStringInput;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.validation.Status;
import java.util.ArrayList;
@ -40,7 +40,7 @@
import java.util.Map;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Convenience static methods for displaying form related information

4
client/src/main/java/org/apache/sqoop/client/utils/FormFiller.java → shell/src/main/java/org/apache/sqoop/shell/utils/FormFiller.java
View File

@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.utils;
package org.apache.sqoop.shell.utils;
import jline.ConsoleReader;
import org.apache.sqoop.model.MBooleanInput;
@ -35,7 +35,7 @@
import java.util.HashMap;
import java.util.ResourceBundle;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Convenient methods for retrieving user input.

6
client/src/main/java/org/apache/sqoop/client/utils/SubmissionDisplayer.java → shell/src/main/java/org/apache/sqoop/shell/utils/SubmissionDisplayer.java
View File

@ -15,10 +15,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.utils;
package org.apache.sqoop.shell.utils;
import org.apache.sqoop.client.core.Constants;
import org.apache.sqoop.model.MSubmission;
import org.apache.sqoop.shell.core.Constants;
import org.apache.sqoop.submission.SubmissionStatus;
import org.apache.sqoop.submission.counter.Counter;
import org.apache.sqoop.submission.counter.CounterGroup;
@ -26,7 +26,7 @@
import java.text.SimpleDateFormat;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Class used for displaying or printing the submission details

4
client/src/main/java/org/apache/sqoop/client/utils/TableDisplayer.java → shell/src/main/java/org/apache/sqoop/shell/utils/TableDisplayer.java
View File

@ -15,14 +15,14 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.utils;
package org.apache.sqoop.shell.utils;
import org.apache.commons.lang.StringUtils;
import java.util.LinkedList;
import java.util.List;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Display table based data

8
client/src/main/java/org/apache/sqoop/client/utils/ThrowableDisplayer.java → shell/src/main/java/org/apache/sqoop/shell/utils/ThrowableDisplayer.java
View File

@ -15,13 +15,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.sqoop.client.utils;
package org.apache.sqoop.shell.utils;
import groovy.lang.MissingPropertyException;
import org.apache.sqoop.client.core.ClientError;
import org.apache.sqoop.common.SqoopException;
import org.apache.sqoop.shell.core.ShellError;
import static org.apache.sqoop.client.shell.ShellEnvironment.*;
import static org.apache.sqoop.shell.ShellEnvironment.*;
/**
* Pretty printing of Throwable objects
@ -44,7 +44,7 @@ public static void errorHook(Throwable t) {
// If this is server exception from server
if(t instanceof SqoopException
&& ((SqoopException)t).getErrorCode() == ClientError.CLIENT_0006) {
&& ((SqoopException)t).getErrorCode() == ShellError.SHELL_0006) {
print("@|red Server has returned exception: |@");
printThrowable(t.getCause(), isVerbose());
} else if(t.getClass() == MissingPropertyException.class) {

24
shell/src/main/resources/log4j.properties Normal file
View File

@ -0,0 +1,24 @@
# 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.
# Set root logger level to DEBUG and its only appender to A1.
log4j.rootLogger=WARN, A1
# A1 is set to be a ConsoleAppender.
log4j.appender.A1=org.apache.log4j.ConsoleAppender
# A1 uses PatternLayout.
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-4r [%t] %-5p %c %x - %m%n

0
client/src/main/resources/client-resource.properties → shell/src/main/resources/shell-resource.properties
View File

24
shell/src/test/resources/log4j.properties Normal file
View File

@ -0,0 +1,24 @@
# 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.
# Set root logger level to DEBUG and its only appender to A1.
log4j.rootLogger=DEBUG, A1
# A1 is set to be a ConsoleAppender.
log4j.appender.A1=org.apache.log4j.ConsoleAppender
# A1 uses PatternLayout.
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-4r [%t] %-5p %c %x - %m%n