IngestionProcess |
|
InterpretationType |
Enum to represent the pipelines internal interpretation type steps.
|
InterpretationType.RecordType |
|
PipelineExecution |
Models an execution of a pipeline that can include one or more steps.
|
PipelineProcess |
Models a pipeline process for a specific dataset and attempt.
|
PipelineStep |
Models a step in pipelines.
|
PipelineStep.MetricInfo |
Inner class to store metrics.
|
PipelineStep.Status |
Enum to represent the status of a step.
|
PipelinesWorkflow.Graph |
|
PipelinesWorkflow.Graph.Edge |
|
RunPipelineResponse |
Encapsulates the possible response of the request of re-execute a pipeline of dataset and
attempt.
|
RunPipelineResponse.Builder |
|
RunPipelineResponse.ResponseStatus |
Possible response statuses.
|
StepRunner |
General runners, STANDALONE - run an app using local resources, DISTRIBUTED - run an app using
YARN cluster.
|
StepType |
Enum to represent the pipelines step names.
|
WorkflowStep |
Models a step in a Pipeline workflow.
|