org.apache.beam.runners.fnexecution.translation

Class PipelineTranslatorUtils

java.lang.Object

org.apache.beam.runners.fnexecution.translation.PipelineTranslatorUtils

public final class PipelineTranslatorUtils
extends java.lang.Object

Utilities for pipeline translation.

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.BiMap<java.lang.String,java.lang.Integer>	createOutputMap(java.lang.Iterable<java.lang.String> localOutputs) Creates a mapping from PCollection id to output tag integer.
static void	fireEligibleTimers(org.apache.beam.runners.core.InMemoryTimerInternals timerInternals, java.util.Map<KV<java.lang.String,java.lang.String>,FnDataReceiver<org.apache.beam.runners.core.construction.Timer>> timerReceivers, java.lang.Object currentTimerKey) Fires all timers which are ready to be fired.
static WindowingStrategy	getWindowingStrategy(java.lang.String pCollectionId, org.apache.beam.model.pipeline.v1.RunnerApi.Components components)
static boolean	hasUnboundedPCollections(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline) Indicates whether the given pipeline has any unbounded PCollections.
static <T> Coder<org.apache.beam.sdk.util.WindowedValue<T>>	instantiateCoder(java.lang.String collectionId, org.apache.beam.model.pipeline.v1.RunnerApi.Components components) Creates a coder for a given PCollection id from the Proto definition.

Methods inherited from class java.lang.Object

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

Method Detail

createOutputMap

public static org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> createOutputMap(java.lang.Iterable<java.lang.String> localOutputs)

Creates a mapping from PCollection id to output tag integer.

instantiateCoder

public static <T> Coder<org.apache.beam.sdk.util.WindowedValue<T>> instantiateCoder(java.lang.String collectionId,
                                                                                    org.apache.beam.model.pipeline.v1.RunnerApi.Components components)

Creates a coder for a given PCollection id from the Proto definition.

getWindowingStrategy

public static WindowingStrategy getWindowingStrategy(java.lang.String pCollectionId,
                                                     org.apache.beam.model.pipeline.v1.RunnerApi.Components components)

hasUnboundedPCollections

public static boolean hasUnboundedPCollections(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline)

Indicates whether the given pipeline has any unbounded PCollections.

fireEligibleTimers

public static void fireEligibleTimers(org.apache.beam.runners.core.InMemoryTimerInternals timerInternals,
                                      java.util.Map<KV<java.lang.String,java.lang.String>,FnDataReceiver<org.apache.beam.runners.core.construction.Timer>> timerReceivers,
                                      java.lang.Object currentTimerKey)

Fires all timers which are ready to be fired. This is done in a loop because timers may itself schedule timers.