org.springframework.xd.sqoop

Class SqoopTasklet

java.lang.Object

org.springframework.batch.step.tasklet.x.AbstractProcessBuilderTasklet

org.springframework.xd.sqoop.SqoopTasklet

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet, org.springframework.batch.core.StepExecutionListener, org.springframework.batch.core.StepListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.EnvironmentAware

public class SqoopTasklet
extends AbstractProcessBuilderTasklet
implements org.springframework.beans.factory.InitializingBean

Tasklet used for running Sqoop tool. Note: This this class is not thread-safe.

Since:

1.1

Author:

Thomas Risberg, Gary Russell

Field Summary

Fields inherited from class org.springframework.batch.step.tasklet.x.AbstractProcessBuilderTasklet

environment, exitCode, logger

Constructor Summary

Constructors

Constructor and Description
SqoopTasklet()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected java.util.List<java.lang.String>	createCommand()
java.lang.String[]	getArguments()
protected java.lang.String	getCommandDescription()
protected java.lang.String	getCommandDisplayString()
protected java.lang.String	getCommandName()
java.util.Properties	getHadoopProperties()
protected boolean	isStoppable()
void	setArguments(java.lang.String[] arguments)
void	setHadoopProperties(java.util.Properties hadoopProperties)
void	setLibjars(java.lang.String libjars)

Methods inherited from class org.springframework.batch.step.tasklet.x.AbstractProcessBuilderTasklet

addEnvironmentProvider, afterStep, beforeStep, execute, getFirstExceptionMessage, getProcessOutput, printLog, setEnvironment, setJobExplorer, setSystemProcessExitCodeMapper, setTerminationCheckInterval

Methods inherited from class java.lang.Object

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

Constructor Detail

SqoopTasklet

public SqoopTasklet()

Method Detail

getArguments

public java.lang.String[] getArguments()

setArguments

public void setArguments(java.lang.String[] arguments)

getHadoopProperties

public java.util.Properties getHadoopProperties()

setHadoopProperties

public void setHadoopProperties(java.util.Properties hadoopProperties)

setLibjars

public void setLibjars(java.lang.String libjars)

isStoppable

protected boolean isStoppable()

Specified by:

isStoppable in class AbstractProcessBuilderTasklet

createCommand

protected java.util.List<java.lang.String> createCommand()

Specified by:

createCommand in class AbstractProcessBuilderTasklet

getCommandDisplayString

protected java.lang.String getCommandDisplayString()

Specified by:

getCommandDisplayString in class AbstractProcessBuilderTasklet

getCommandName

protected java.lang.String getCommandName()

Specified by:

getCommandName in class AbstractProcessBuilderTasklet

getCommandDescription

protected java.lang.String getCommandDescription()

Specified by:

getCommandDescription in class AbstractProcessBuilderTasklet

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception