org.apache.beam.runners.dataflow

Interface 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

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<?,?,?>	getCurrentParent() Gets the parent composite transform to the current transform, if one exists.
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<?>,PCollection<?>>	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<?>,PCollection<?>>	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()
default boolean	isFnApi()
default boolean	isStreamingEngine()

Method Detail

isFnApi

default boolean isFnApi()

isStreamingEngine

default boolean isStreamingEngine()

getPipelineOptions

DataflowPipelineOptions getPipelineOptions()

Returns the configured pipeline options.

getInputs

<InputT extends PInput> java.util.Map<TupleTag<?>,PCollection<?>> 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<?>,PCollection<?>> 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.

getCurrentParent

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

Gets the parent composite transform to the current transform, if one exists. Otherwise returns one null.