org.apache.beam.sdk.util.construction

Class PrimitiveCreate.Factory<T>

java.lang.Object

org.apache.beam.sdk.util.construction.PrimitiveCreate.Factory<T>

All Implemented Interfaces:

PTransformOverrideFactory<PBegin,PCollection<T>,Create.Values<T>>

Enclosing class:

PrimitiveCreate<T>

public static class PrimitiveCreate.Factory<T>
extends java.lang.Object
implements PTransformOverrideFactory<PBegin,PCollection<T>,Create.Values<T>>

A PTransformOverrideFactory that creates instances of PrimitiveCreate.

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

Constructor Summary

Constructors

Constructor and Description
Factory()

Method Summary

Modifier and Type	Method and Description
PTransformOverrideFactory.PTransformReplacement<PBegin,PCollection<T>>	getReplacementTransform(AppliedPTransform<PBegin,PCollection<T>,Create.Values<T>> 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, PCollection<T> newOutput) Returns a Map from the expanded values in newOutput to the values produced by the original transform.

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory()

Method Detail

getReplacementTransform

public PTransformOverrideFactory.PTransformReplacement<PBegin,PCollection<T>> getReplacementTransform(AppliedPTransform<PBegin,PCollection<T>,Create.Values<T>> transform)

Description copied from interface: PTransformOverrideFactory

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

Specified by:

getReplacementTransform in interface PTransformOverrideFactory<PBegin,PCollection<T>,Create.Values<T>>

mapOutputs

public java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> mapOutputs(java.util.Map<TupleTag<?>,PCollection<?>> outputs,
                                                                                            PCollection<T> 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<PBegin,PCollection<T>,Create.Values<T>>