org.springframework.data.hadoop.cascading
Class CascadeTasklet

java.lang.Object
  org.springframework.data.hadoop.cascading.CascadeTasklet

All Implemented Interfaces:

Tasklet

public class CascadeTasklet
extends Object
implements Tasklet

Batch tasklet for executing a Cascade or a Flow as part of a job.

Author:

Costin Leau

Constructor Summary

CascadeTasklet()

Method Summary

RepeatStatus	execute(StepContribution contribution, ChunkContext chunkContext)
void	setUnitOfWork(cascading.management.UnitOfWork<CascadingStats> unitOfWork) Sets the unit of work.

Methods inherited from class java.lang.Object

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

Constructor Detail

CascadeTasklet

public CascadeTasklet()

Method Detail

execute

public RepeatStatus execute(StepContribution contribution,
                            ChunkContext chunkContext)
                     throws Exception

Specified by:

execute in interface Tasklet

Throws:

Exception

setUnitOfWork

public void setUnitOfWork(cascading.management.UnitOfWork<CascadingStats> unitOfWork)

Sets the unit of work. Can be of type Flow or Cascade.

Parameters:

unitOfWork - the new cascade