Package org.apache.beam.runners.flink

Class FlinkStreamingPortablePipelineTranslator.IsFlinkNativeTransform

java.lang.Object

org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.IsFlinkNativeTransform

All Implemented Interfaces:

Predicate<org.apache.beam.model.pipeline.v1.RunnerApi.PTransform>, org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform

Enclosing class:

FlinkStreamingPortablePipelineTranslator

@AutoService(org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform.class)
public static class FlinkStreamingPortablePipelineTranslator.IsFlinkNativeTransform
extends Object
implements org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform

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

Constructor Summary

Constructors

Constructor	Description
IsFlinkNativeTransform()

Method Summary

Modifier and Type	Method	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, negate, or

Constructor Details

IsFlinkNativeTransform

public IsFlinkNativeTransform()

Method Details

test

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

Specified by:

test in interface org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform

Specified by:

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