- All Implemented Interfaces:
- java.util.function.Predicate<org.apache.beam.model.pipeline.v1.RunnerApi.PTransform>, org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform
- Enclosing class:
- FlinkBatchPortablePipelineTranslator
@AutoService(value=org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform.class)
public static class FlinkBatchPortablePipelineTranslator.IsFlinkNativeTransform
extends java.lang.Object
implements org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform
Predicate to determine whether a URN is a Flink native transform.