TransformTranslator.TranslationContext

Enclosing interface:

TransformTranslator<TransformT extends PTransform>
```
public static interface TransformTranslator.TranslationContext
```
The interface provided to registered callbacks for interacting with the DataflowRunner, including reading and writing the values of PCollections and side inputs.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`TransformTranslator.StepTranslationContext`	`addStep(PTransform<?,?> transform, java.lang.String type)` Adds a step to the Dataflow workflow for the given transform, with the given Dataflow step type.
`OutputReference`	`asOutputReference(PValue value, org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> producer)` Encode a PValue reference as an output reference.
`org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>`	`getCurrentTransform()`
`java.lang.String`	`getFullName(PTransform<?,?> transform)` Returns the full name of the currently being translated transform.
`<InputT extends PValue> InputT`	`getInput(PTransform<InputT,?> transform)`
`<InputT extends PInput> java.util.Map<TupleTag<?>,PValue>`	`getInputs(PTransform<InputT,?> transform)` Returns the input of the currently being translated transform.
`<OutputT extends PValue> OutputT`	`getOutput(PTransform<?,OutputT> transform)`
`<OutputT extends POutput> java.util.Map<TupleTag<?>,PValue>`	`getOutputs(PTransform<?,OutputT> transform)` Returns the output of the currently being translated transform.
`DataflowPipelineOptions`	`getPipelineOptions()` Returns the configured pipeline options.
`org.apache.beam.sdk.runners.AppliedPTransform<?,?,?>`	`getProducer(PValue value)` Get the `AppliedPTransform` that produced the provided `PValue`.
`org.apache.beam.runners.core.construction.SdkComponents`	`getSdkComponents()`

Method Detail

getPipelineOptions
```
DataflowPipelineOptions getPipelineOptions()
```
Returns the configured pipeline options.

getInputs

<InputT extends PInput> java.util.Map<TupleTag<?>,PValue> getInputs(PTransform<InputT,?> transform)

Returns the input of the currently being translated transform.

getInput

<InputT extends PValue> InputT getInput(PTransform<InputT,?> transform)

getOutputs

<OutputT extends POutput> java.util.Map<TupleTag<?>,PValue> getOutputs(PTransform<?,OutputT> transform)

Returns the output of the currently being translated transform.

getOutput

<OutputT extends PValue> OutputT getOutput(PTransform<?,OutputT> transform)

getFullName
```
java.lang.String getFullName(PTransform<?,?> transform)
```
Returns the full name of the currently being translated transform.

addStep

TransformTranslator.StepTranslationContext addStep(PTransform<?,?> transform,
                                                   java.lang.String type)

Adds a step to the Dataflow workflow for the given transform, with the given Dataflow step type.

asOutputReference

OutputReference asOutputReference(PValue value,
                                  org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> producer)

Encode a PValue reference as an output reference.

getSdkComponents

org.apache.beam.runners.core.construction.SdkComponents getSdkComponents()

getCurrentTransform

org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> getCurrentTransform()

getProducer

org.apache.beam.sdk.runners.AppliedPTransform<?,?,?> getProducer(PValue value)

Get the AppliedPTransform that produced the provided PValue.

Interface TransformTranslator.TranslationContext