org.springframework.data.hadoop.batch.sqoop2

Class Sqoop2Tasklet

java.lang.Object

org.springframework.data.hadoop.batch.sqoop2.Sqoop2Tasklet

All Implemented Interfaces:

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

public class Sqoop2Tasklet
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.batch.core.step.tasklet.Tasklet, org.springframework.batch.core.StepExecutionListener

Sqoop2 tasklet running Sqoop2 jobs on demand.

Author:

Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
Sqoop2Tasklet()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
org.springframework.batch.core.ExitStatus	afterStep(org.springframework.batch.core.StepExecution stepExecution)
void	beforeStep(org.springframework.batch.core.StepExecution stepExecution)
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext)
void	setJobId(java.lang.Long jobId)
void	setPollTime(java.lang.Long pollTime)
void	setSqoopUrl(java.lang.String sqoopUrl)

Methods inherited from class java.lang.Object

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

Constructor Detail

Sqoop2Tasklet

public Sqoop2Tasklet()

Method Detail

setSqoopUrl

public void setSqoopUrl(java.lang.String sqoopUrl)

setJobId

public void setJobId(java.lang.Long jobId)

setPollTime

public void setPollTime(java.lang.Long pollTime)

execute

public org.springframework.batch.repeat.RepeatStatus execute(org.springframework.batch.core.StepContribution contribution,
                                                    org.springframework.batch.core.scope.context.ChunkContext chunkContext)
                                                      throws java.lang.Exception

Specified by:

execute in interface org.springframework.batch.core.step.tasklet.Tasklet

Throws:

java.lang.Exception

beforeStep

public void beforeStep(org.springframework.batch.core.StepExecution stepExecution)

Specified by:

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

afterStep

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

Specified by:

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

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception