cascading.flow
Class FlowStep.FlowStepJob

java.lang.Object
  cascading.flow.FlowStep.FlowStepJob

All Implemented Interfaces:

Callable<Throwable>

Enclosing class:

FlowStep

public class FlowStep.FlowStepJob
extends Object
implements Callable<Throwable>

Constructor Summary

FlowStep.FlowStepJob(String stepName, JobConf currentConf)

Method Summary

Throwable	call()
boolean	isSuccessful() Method isSuccessful returns true if this step completed successfully.
void	setPredecessors(List<FlowStep.FlowStepJob> predecessors)
void	stop()
boolean	wasStarted() Method wasStarted returns true if this job was started

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowStep.FlowStepJob

public FlowStep.FlowStepJob(String stepName,
                            JobConf currentConf)

Method Detail

stop

public void stop()

setPredecessors

public void setPredecessors(List<FlowStep.FlowStepJob> predecessors)
                     throws IOException

Throws:

IOException

call

public Throwable call()

Specified by:

call in interface Callable<Throwable>

isSuccessful

public boolean isSuccessful()

Method isSuccessful returns true if this step completed successfully.

Returns:

the successful (type boolean) of this FlowStepJob object.

wasStarted

public boolean wasStarted()

Method wasStarted returns true if this job was started

Returns:

boolean