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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CascadeTasklet
public CascadeTasklet()
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