|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||
| Interface Summary | |
|---|---|
| ErrorHandler | |
| StageExecutionStatus | |
| StageExecutor | This interface marks classes that can be used to execute TupleFlow job stages. |
| StepSpecification | There are a few different things this interface needs to support. |
| Class Summary | |
|---|---|
| Chain | |
| Connection | Represents a data connection between two stages in a TupleFlow job. |
| ConnectionEndPoint | |
| DataPipe | |
| ErrorExecutionStatus | A dummy execution status object that wraps an error. |
| ErrorStore | |
| ErrorStore.Statement | |
| FileLocation | |
| InputStep | Represents an input step in a TupleFlow stage. |
| Job | A Job object specifies a TupleFlow execution: the objects used, their parameters, and how they communicate. |
| Job.StagePoint | |
| JobConnectionEndPoint | |
| JobConstructor | |
| JobExecutor | This class is responsible for executing TupleFlow jobs. |
| JobExecutor.JobExecutionStatus | |
| LocalRemoteStageExecutor | This executor has no practical use at all. |
| LocalStageExecutor | |
| LocalStageExecutor.SequentialExecutionContext | |
| Locatable | This is a mixin class that allows a Job stage/step class to be associated with a file location. |
| MasterWebHandler | This handler creates a web interface for checking on the status of a running TupleFlow job. |
| MasterWebHandler.CounterName | |
| MultiStep | Represents a multi block in a TupleFlow stage. |
| NetworkedCounter | |
| NetworkedCounterManager | |
| OutputStep | Represents an output step in a TupleFlow stage. |
| RemoteStageExecutor | |
| SSHStageExecutor | This will eventually allow you to run TupleFlow workers on other machines using SSH. |
| StackHandler | |
| Stage | This is a stage description for a TupleFlow job. |
| StageConnectionPoint | Represents an endpoint for a connection within a TupleFlow stage. |
| StageExecutorFactory | |
| StageGroupDescription | |
| StageGroupDescription.DataPipeRegion | |
| StageInstanceDescription | |
| StageInstanceDescription.PipeInput | |
| StageInstanceDescription.PipeOutput | |
| StageInstanceFactory | |
| Step | |
| ThreadedStageExecutor | |
| ThreadedStageExecutor.InstanceRunnable | |
| Verification | |
| Enum Summary | |
|---|---|
| ConnectionAssignmentType | This specifies how input data should be assigned to outputs in a TupleFlow connection. |
| ConnectionPointType | Represents the end point type of a TupleFlow connection: either input or output. |
| Annotation Types Summary | |
|---|---|
| Verified | This annotation is applied to Step classes that don't need any extra verification before they're executed. |
|
||||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | |||||||||