org.apache.beam.sdk.util.construction

Class UnsupportedOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>>

java.lang.Object

org.apache.beam.sdk.util.construction.UnsupportedOverrideFactory<InputT,OutputT,TransformT>

All Implemented Interfaces:

PTransformOverrideFactory<InputT,OutputT,TransformT>

public final class UnsupportedOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>>
extends java.lang.Object
implements PTransformOverrideFactory<InputT,OutputT,TransformT>

A PTransformOverrideFactory that throws an exception when a call to getReplacementTransform(AppliedPTransform) is made. This is for PTransforms which are not supported by a runner.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput>, PTransformOverrideFactory.ReplacementOutput

Method Summary

Modifier and Type	Method and Description
PTransformOverrideFactory.PTransformReplacement<InputT,OutputT>	getReplacementTransform(AppliedPTransform<InputT,OutputT,TransformT> transform) Returns a PTransform that produces equivalent output to the provided transform.
java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput>	mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs, OutputT newOutput) Returns a Map from the expanded values in newOutput to the values produced by the original transform.
static <InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>> UnsupportedOverrideFactory<InputT,OutputT,TransformT>	withMessage(java.lang.String message)

Methods inherited from class java.lang.Object

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

Method Detail

withMessage

public static <InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>> UnsupportedOverrideFactory<InputT,OutputT,TransformT> withMessage(java.lang.String message)

getReplacementTransform

public PTransformOverrideFactory.PTransformReplacement<InputT,OutputT> getReplacementTransform(AppliedPTransform<InputT,OutputT,TransformT> transform)

Description copied from interface: PTransformOverrideFactory

Returns a PTransform that produces equivalent output to the provided transform.

Specified by:

getReplacementTransform in interface PTransformOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>>

mapOutputs

public java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs,
                                                                                            OutputT newOutput)

Description copied from interface: PTransformOverrideFactory

Returns a Map from the expanded values in newOutput to the values produced by the original transform.

Specified by:

mapOutputs in interface PTransformOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>>