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

Constructor Summary

CascadeRunner()

Method Summary

void	afterPropertiesSet()
void	destroy()
CascadingStats	getObject()
Class	getObjectType()
boolean	isSingleton()
void	setRunAtStartup(boolean runAtStartup) Sets the run at startup.
void	setUnitOfWork(cascading.management.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

CascadeRunner

public CascadeRunner()

Method Detail

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.