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

java.lang.Object
  extended by org.springframework.data.hadoop.pig.PigExecutor
      extended by org.springframework.data.hadoop.batch.pig.PigTasklet
All Implemented Interfaces:
Tasklet, InitializingBean

public class PigTasklet
extends org.springframework.data.hadoop.pig.PigExecutor
implements Tasklet

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

Author:
Costin Leau

Constructor Summary
PigTasklet()
           
 
Method Summary
 RepeatStatus execute(StepContribution contribution, 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 RepeatStatus execute(StepContribution contribution,
                            ChunkContext chunkContext)
                     throws Exception
Specified by:
execute in interface Tasklet
Throws:
Exception