|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.hadoop.cascading.CascadingRunner
public class CascadingRunner
Simple runner for executing Cascade
s or Flow
s. By default, the runner waits for the jobs to finish and returns its status.
To make the runner execute at startup, use setRunAtStartup(boolean)
.
Field Summary | |
---|---|
protected Log |
log
|
protected UnitOfWork<? extends CascadingStats> |
uow
|
protected boolean |
waitToComplete
|
Constructor Summary | |
---|---|
CascadingRunner()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
CascadingStats |
call()
|
void |
destroy()
|
protected CascadingStats |
execute()
|
boolean |
isWaitForCompletion()
Indicates whether the 'runner' should wait for the UnitOfWork to complete (default). |
void |
setPostAction(Collection<Callable<?>> actions)
Actions to be invoked after running the action. |
void |
setPreAction(Collection<Callable<?>> actions)
Actions to be invoked before running the action. |
void |
setRunAtStartup(boolean runAtStartup)
Sets the run at startup. |
void |
setUnitOfWork(UnitOfWork<? extends CascadingStats> uow)
Sets the unit of work. |
void |
setWaitForCompletion(boolean waitForCompletion)
Indicates whether the 'runner' should wait for the UnitOfWork to complete (default) after submission or not. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected boolean waitToComplete
protected UnitOfWork<? extends CascadingStats> uow
protected Log log
Constructor Detail |
---|
public CascadingRunner()
Method Detail |
---|
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface InitializingBean
Exception
public CascadingStats call() throws Exception
call
in interface Callable<CascadingStats>
Exception
public void setRunAtStartup(boolean runAtStartup)
runAtStartup
- The runAtStartup to set.public void setPreAction(Collection<Callable<?>> actions)
actions
- public void setPostAction(Collection<Callable<?>> actions)
actions
- protected CascadingStats execute()
public void destroy()
destroy
in interface DisposableBean
public void setUnitOfWork(UnitOfWork<? extends CascadingStats> uow)
Flow
or Cascade
.
uow
- the new unit of work.public boolean isWaitForCompletion()
public void setWaitForCompletion(boolean waitForCompletion)
waitForCompletion
- whether to wait for the unit to complete or not.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |