org.springframework.data.hadoop.cascading
Class CascadingTasklet
java.lang.Object
org.springframework.data.hadoop.cascading.CascadingTasklet
- All Implemented Interfaces:
- Tasklet, DisposableBean
public class CascadingTasklet
- extends Object
- implements Tasklet
Batch tasklet for executing a Cascade
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 |
waitToComplete
protected boolean waitToComplete
uow
protected UnitOfWork<? extends CascadingStats> uow
log
protected org.apache.commons.logging.Log log
CascadingTasklet
public CascadingTasklet()
execute
public RepeatStatus execute(StepContribution contribution,
ChunkContext chunkContext)
throws Exception
- Specified by:
execute
in interface Tasklet
- Throws:
Exception
execute
protected CascadingStats execute()
destroy
public void destroy()
- Specified by:
destroy
in interface DisposableBean
setUnitOfWork
public void setUnitOfWork(UnitOfWork<? extends CascadingStats> uow)
- Sets the unit of work. Can be of type
Flow
or Cascade
.
- Parameters:
uow
- the new unit of work.
isWaitForCompletion
public boolean isWaitForCompletion()
- Indicates whether the 'runner' should wait for the UnitOfWork to complete (default).
- Returns:
- whether the runner waits for the unit to complete or not.
setWaitForCompletion
public void setWaitForCompletion(boolean waitForCompletion)
- Indicates whether the 'runner' should wait for the UnitOfWork to complete (default)
after submission or not.
- Parameters:
waitForCompletion
- whether to wait for the unit to complete or not.