org.springframework.batch.integration.x

Class RemoteFileToHadoopTasklet

java.lang.Object

org.springframework.batch.integration.x.RemoteFileToHadoopTasklet

All Implemented Interfaces:

org.springframework.batch.core.step.tasklet.Tasklet

public class RemoteFileToHadoopTasklet
extends java.lang.Object
implements org.springframework.batch.core.step.tasklet.Tasklet

Retrieves a fileName from the step execution context; uses the RemoteFileTemplate to retrieve the file as a String and writes to hdfs.

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
RemoteFileToHadoopTasklet(org.springframework.integration.file.remote.RemoteFileTemplate template, org.apache.hadoop.conf.Configuration configuration, java.lang.String hdfsDirectory)

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.repeat.RepeatStatus	execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteFileToHadoopTasklet

public RemoteFileToHadoopTasklet(org.springframework.integration.file.remote.RemoteFileTemplate template,
                         org.apache.hadoop.conf.Configuration configuration,
                         java.lang.String hdfsDirectory)

Method Detail

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