org.apache.beam.runners.core.construction

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

java.lang.Object

org.apache.beam.runners.core.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 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)
Map<PValue,PTransformOverrideFactory.ReplacementOutput>	mapOutputs(Map<TupleTag<?>,PValue> outputs, OutputT newOutput)
static <InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>> UnsupportedOverrideFactory<InputT,OutputT,TransformT>	withMessage(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(String message)

getReplacementTransform

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

Specified by:

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

mapOutputs

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

Specified by:

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