Package org.apache.beam.runners.spark.translation

Class SparkBatchPortablePipelineTranslator.IsSparkNativeTransform

java.lang.Object

org.apache.beam.runners.spark.translation.SparkBatchPortablePipelineTranslator.IsSparkNativeTransform

All Implemented Interfaces:

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

Enclosing class:

SparkBatchPortablePipelineTranslator

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

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

Constructor Summary

Constructors

Constructor	Description
IsSparkNativeTransform()

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

IsSparkNativeTransform

public IsSparkNativeTransform()

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>