org.apache.beam.sdk.util.construction

Class ReplacementOutputs

java.lang.Object

org.apache.beam.sdk.util.construction.ReplacementOutputs

public class ReplacementOutputs
extends java.lang.Object

Utility methods for creating PTransformOverrideFactory.ReplacementOutput for known styles of POutput.

Method Summary

Modifier and Type	Method and Description
static java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput>	singleton(java.util.Map<TupleTag<?>,PCollection<?>> original, POutput replacement)
static java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput>	tagged(java.util.Map<TupleTag<?>,PCollection<?>> original, POutput replacement)

Methods inherited from class java.lang.Object

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

Method Detail

singleton

public static java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> singleton(java.util.Map<TupleTag<?>,PCollection<?>> original,
                                                                                                  POutput replacement)

tagged

public static java.util.Map<PCollection<?>,PTransformOverrideFactory.ReplacementOutput> tagged(java.util.Map<TupleTag<?>,PCollection<?>> original,
                                                                                               POutput replacement)