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 Cascade
s or Flow
s. 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.