org.apache.beam.runners.flink

Class FlinkBatchPortablePipelineTranslator.IsFlinkNativeTransform

java.lang.Object

org.apache.beam.runners.flink.FlinkBatchPortablePipelineTranslator.IsFlinkNativeTransform

All Implemented Interfaces:

java.util.function.Predicate<org.apache.beam.model.pipeline.v1.RunnerApi.PTransform>, org.apache.beam.runners.core.construction.NativeTransforms.IsNativeTransform

Enclosing class:

FlinkBatchPortablePipelineTranslator

@AutoService(value=org.apache.beam.runners.core.construction.NativeTransforms.IsNativeTransform.class)
public static class FlinkBatchPortablePipelineTranslator.IsFlinkNativeTransform
extends java.lang.Object
implements org.apache.beam.runners.core.construction.NativeTransforms.IsNativeTransform

Predicate to determine whether a URN is a Flink native transform.

Constructor Summary

Constructors

Constructor and Description
IsFlinkNativeTransform()

Method Summary

Modifier and Type	Method and Description
boolean	test(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Constructor Detail

IsFlinkNativeTransform

public IsFlinkNativeTransform()

Method Detail

test

public boolean test(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)

Specified by:

test in interface java.util.function.Predicate<org.apache.beam.model.pipeline.v1.RunnerApi.PTransform>

Specified by:

test in interface org.apache.beam.runners.core.construction.NativeTransforms.IsNativeTransform