org.springframework.data.hadoop.batch.pig
Class PigTasklet

java.lang.Object
  org.springframework.data.hadoop.pig.PigExecutor
      org.springframework.data.hadoop.batch.pig.PigTasklet

All Implemented Interfaces:

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

public class PigTasklet
extends PigExecutor
implements org.springframework.batch.core.step.tasklet.Tasklet

Pig tasklet. Note the same PigServer is shared between invocations.

Author:

Costin Leau

Constructor Summary

PigTasklet()

Method Summary

org.springframework.batch.repeat.RepeatStatus

execute(org.springframework.batch.core.StepContribution contribution, org.springframework.batch.core.scope.context.ChunkContext chunkContext)

Methods inherited from class org.springframework.data.hadoop.pig.PigExecutor

afterPropertiesSet, executePigScripts, setPigFactory, setPigTemplate, setScripts

Methods inherited from class java.lang.Object

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

Constructor Detail

PigTasklet

public PigTasklet()

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