org.springframework.xd.gpload

Class GploadTasklet

java.lang.Object

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

org.springframework.xd.gpload.GploadTasklet

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 GploadTasklet
extends AbstractProcessBuilderTasklet
implements org.springframework.beans.factory.InitializingBean

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

Since:

1.2

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
GploadTasklet()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
org.springframework.batch.core.ExitStatus	afterStep(org.springframework.batch.core.StepExecution stepExecution)
protected java.util.List<java.lang.String>	createCommand()
protected java.lang.String	getCommandDescription()
protected java.lang.String	getCommandDisplayString()
protected java.lang.String	getCommandName()
java.lang.String	getControlFile()
java.lang.String	getDatabase()
java.lang.String	getGploadHome()
java.lang.String	getHost()
java.lang.String	getInputSourceFile()
java.lang.String	getOptions()
java.lang.String	getPassword()
java.lang.String	getPasswordFile()
int	getPort()
java.lang.String	getUsername()
protected boolean	isStoppable()
protected static void	replaceInputSourceFile(java.lang.Object data, java.lang.String inputSourceFile)
void	setControlFile(java.lang.String controlFile)
void	setDatabase(java.lang.String database)
void	setGploadHome(java.lang.String gploadHome)
void	setHost(java.lang.String host)
void	setInputSourceFile(java.lang.String inputSourceFile)
void	setOptions(java.lang.String options)
void	setPassword(java.lang.String password)
void	setPasswordFile(java.lang.String passwordFile)
void	setPort(java.lang.Integer port)
void	setUsername(java.lang.String username)

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

addEnvironmentProvider, 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

GploadTasklet

public GploadTasklet()

Method Detail

getGploadHome

public java.lang.String getGploadHome()

setGploadHome

public void setGploadHome(java.lang.String gploadHome)

getControlFile

public java.lang.String getControlFile()

setControlFile

public void setControlFile(java.lang.String controlFile)

getOptions

public java.lang.String getOptions()

setOptions

public void setOptions(java.lang.String options)

getInputSourceFile

public java.lang.String getInputSourceFile()

setInputSourceFile

public void setInputSourceFile(java.lang.String inputSourceFile)

getDatabase

public java.lang.String getDatabase()

setDatabase

public void setDatabase(java.lang.String database)

getHost

public java.lang.String getHost()

setHost

public void setHost(java.lang.String host)

getPort

public int getPort()

setPort

public void setPort(java.lang.Integer port)

getUsername

public java.lang.String getUsername()

setUsername

public void setUsername(java.lang.String username)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

getPasswordFile

public java.lang.String getPasswordFile()

setPasswordFile

public void setPasswordFile(java.lang.String passwordFile)

isStoppable

protected boolean isStoppable()

Specified by:

isStoppable in class AbstractProcessBuilderTasklet

createCommand

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

Specified by:

createCommand in class AbstractProcessBuilderTasklet

Throws:

java.lang.Exception

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

afterStep

public org.springframework.batch.core.ExitStatus afterStep(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

afterStep in interface org.springframework.batch.core.StepExecutionListener

Overrides:

afterStep 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

replaceInputSourceFile

protected static void replaceInputSourceFile(java.lang.Object data,
                          java.lang.String inputSourceFile)