org.springframework.data.hadoop.cascading
Class CascadeRunner
java.lang.Object
org.springframework.data.hadoop.cascading.CascadeRunner
- All Implemented Interfaces:
- DisposableBean, FactoryBean<CascadingStats>, InitializingBean
public class CascadeRunner
- extends Object
- implements InitializingBean, DisposableBean, FactoryBean<CascadingStats>
Simple runner for executing Cascades or Flows. By default, the runner waits for the jobs to finish and returns its status.
- Author:
- Costin Leau
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CascadeRunner
public CascadeRunner()
afterPropertiesSet
public void afterPropertiesSet()
- Specified by:
afterPropertiesSet in interface InitializingBean
destroy
public void destroy()
- Specified by:
destroy in interface DisposableBean
getObject
public CascadingStats getObject()
- Specified by:
getObject in interface FactoryBean<CascadingStats>
getObjectType
public Class getObjectType()
- Specified by:
getObjectType in interface FactoryBean<CascadingStats>
isSingleton
public boolean isSingleton()
- Specified by:
isSingleton in interface FactoryBean<CascadingStats>
setUnitOfWork
public void setUnitOfWork(cascading.management.UnitOfWork<CascadingStats> uow)
- Sets the unit of work. Can be of type
Flow or Cascade.
- Parameters:
uow - the new unit of work.
setRunAtStartup
public void setRunAtStartup(boolean runAtStartup)
- Sets the run at startup.
- Parameters:
runAtStartup - The runAtStartup to set.