Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.runners
Class DataflowPipelineTranslator.JobSpecification
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.runners.DataflowPipelineTranslator.JobSpecification
-
- Enclosing class:
- DataflowPipelineTranslator
public static class DataflowPipelineTranslator.JobSpecification extends 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 thePTransform
to StepName mapping).
-
-
Constructor Summary
Constructors Constructor and Description JobSpecification(com.google.api.services.dataflow.model.Job job, Map<AppliedPTransform<?,?,?>,String> stepNames)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description com.google.api.services.dataflow.model.Job
getJob()
Map<AppliedPTransform<?,?,?>,String>
getStepNames()
Returns the mapping ofAppliedPTransforms
to the internal step name for thatAppliedPTransform
.
-
-
-
Constructor Detail
-
JobSpecification
public JobSpecification(com.google.api.services.dataflow.model.Job job, Map<AppliedPTransform<?,?,?>,String> stepNames)
-
-
Method Detail
-
getJob
public com.google.api.services.dataflow.model.Job getJob()
-
getStepNames
public Map<AppliedPTransform<?,?,?>,String> getStepNames()
Returns the mapping ofAppliedPTransforms
to the internal step name for thatAppliedPTransform
.
-
-