org.apache.beam.runners.dataflow

Class DataflowPipelineTranslator.JobSpecification

java.lang.Object

org.apache.beam.runners.dataflow.DataflowPipelineTranslator.JobSpecification

Enclosing class:

DataflowPipelineTranslator

public static class DataflowPipelineTranslator.JobSpecification
extends java.lang.Object

The result of a job translation.

Used to pass the result Job and any state that was used to construct the job that may be of use to other classes (eg the PTransform to StepName mapping).

Constructor Summary

Constructors

Constructor and Description
JobSpecification(Job job, org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipelineProto, java.util.Map<org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>,java.lang.String> stepNames)

Method Summary

Modifier and Type	Method and Description
Job	getJob()
org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline	getPipelineProto()
java.util.Map<org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>,java.lang.String>	getStepNames() Returns the mapping of AppliedPTransforms to the internal step name for that AppliedPTransform.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobSpecification

public JobSpecification(Job job,
                        org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipelineProto,
                        java.util.Map<org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>,java.lang.String> stepNames)

Method Detail

getJob

public Job getJob()

getPipelineProto

public org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline getPipelineProto()

getStepNames

public java.util.Map<org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>,java.lang.String> getStepNames()

Returns the mapping of AppliedPTransforms to the internal step name for that AppliedPTransform.