org.springframework.xd.sqoop

Class SqoopRunner

java.lang.Object

org.springframework.xd.sqoop.SqoopRunner

public class SqoopRunner
extends java.lang.Object

Class for running Sqoop tool.

Since:

1.1

Author:

Thomas Risberg

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SECURITY_AUTH_METHOD
static java.lang.String	SECURITY_MAPREDUCE_JOBHISTORY_PRINCIPAL
static java.lang.String	SECURITY_NAMENODE_PRINCIPAL
static java.lang.String	SECURITY_RM_MANAGER_PRINCIPAL
static java.lang.String	SECURITY_USER_KEYTAB
static java.lang.String	SECURITY_USER_PRINCIPAL

Constructor Summary

Constructors

Constructor and Description
SqoopRunner()

Method Summary

Methods

Modifier and Type	Method and Description
protected static org.apache.hadoop.conf.Configuration	createConfiguration(java.util.Map<java.lang.String,java.lang.String> configOptions)
protected static void	createFinalArguments(java.lang.String hadoopMapredHome, java.lang.String command, java.util.List<java.lang.String> sqoopArguments, boolean provideConnect, java.util.Map<java.lang.String,java.lang.String> configOptions, java.util.List<java.lang.String> finalArguments)
static void	main(java.lang.String[] args)
protected static void	parseConfigOptions(java.lang.String[] args, java.util.Map<java.lang.String,java.lang.String> configOptions)
protected static boolean	parseSqoopCommandArguments(java.lang.String command, java.lang.String[] sqoopArguments, java.util.List<java.lang.String> runtimeArguments)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SECURITY_AUTH_METHOD

public static final java.lang.String SECURITY_AUTH_METHOD

See Also:

Constant Field Values

SECURITY_USER_KEYTAB

public static final java.lang.String SECURITY_USER_KEYTAB

See Also:

Constant Field Values

SECURITY_USER_PRINCIPAL

public static final java.lang.String SECURITY_USER_PRINCIPAL

See Also:

Constant Field Values

SECURITY_NAMENODE_PRINCIPAL

public static final java.lang.String SECURITY_NAMENODE_PRINCIPAL

See Also:

Constant Field Values

SECURITY_RM_MANAGER_PRINCIPAL

public static final java.lang.String SECURITY_RM_MANAGER_PRINCIPAL

See Also:

Constant Field Values

SECURITY_MAPREDUCE_JOBHISTORY_PRINCIPAL

public static final java.lang.String SECURITY_MAPREDUCE_JOBHISTORY_PRINCIPAL

See Also:

Constant Field Values

Constructor Detail

SqoopRunner

public SqoopRunner()

Method Detail

main

public static void main(java.lang.String[] args)

createFinalArguments

protected static void createFinalArguments(java.lang.String hadoopMapredHome,
                        java.lang.String command,
                        java.util.List<java.lang.String> sqoopArguments,
                        boolean provideConnect,
                        java.util.Map<java.lang.String,java.lang.String> configOptions,
                        java.util.List<java.lang.String> finalArguments)

createConfiguration

protected static org.apache.hadoop.conf.Configuration createConfiguration(java.util.Map<java.lang.String,java.lang.String> configOptions)

parseConfigOptions

protected static void parseConfigOptions(java.lang.String[] args,
                      java.util.Map<java.lang.String,java.lang.String> configOptions)

parseSqoopCommandArguments

protected static boolean parseSqoopCommandArguments(java.lang.String command,
                                 java.lang.String[] sqoopArguments,
                                 java.util.List<java.lang.String> runtimeArguments)