Package org.apache.beam.runners.flink.translation.utils

Class FlinkPortableRunnerUtils

java.lang.Object

org.apache.beam.runners.flink.translation.utils.FlinkPortableRunnerUtils

public class FlinkPortableRunnerUtils
extends Object

Various utilies related to portability. Helps share code between portable batch and streaming translator.

Method Summary

Modifier and Type	Method	Description
static boolean	requiresStableInput(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload payload)
static boolean	requiresTimeSortedInput(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload payload, boolean streaming)

Methods inherited from class java.lang.Object

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

Method Details

requiresTimeSortedInput

public static boolean requiresTimeSortedInput(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload payload,
 boolean streaming)

requiresStableInput

public static boolean requiresStableInput(org.apache.beam.model.pipeline.v1.RunnerApi.ExecutableStagePayload payload)