|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.hadoop.cascading.CascadeRunner
public class CascadeRunner
Simple runner for executing Cascades or Flows. By default, the runner waits for the jobs to finish and returns its status.
To make the runner execute at startup, use setRunAtStartup(boolean).
| Constructor Summary | |
|---|---|
CascadeRunner()
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
|
CascadingStats |
call()
|
void |
destroy()
|
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<CascadingStats> uow)
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 |
|---|
public CascadeRunner()
| Method Detail |
|---|
public void afterPropertiesSet()
throws Exception
afterPropertiesSet in interface InitializingBeanExceptionpublic void destroy()
destroy in interface DisposableBean
public CascadingStats call()
throws Exception
call in interface Callable<CascadingStats>Exceptionpublic void setUnitOfWork(UnitOfWork<CascadingStats> uow)
Flow or Cascade.
uow - the new unit of work.public void setRunAtStartup(boolean runAtStartup)
runAtStartup - The runAtStartup to set.public void setPreAction(Collection<Callable<?>> actions)
actions - public void setPostAction(Collection<Callable<?>> actions)
actions -
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||