Package org.apache.beam.sdk.runners
Interface PTransformMatcher
-
@Internal @Experimental(CORE_RUNNERS_ONLY) public interface PTransformMatcher
For internal use only; no backwards-compatibility guarantees.Matches applications of
PTransforms
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default PTransformMatcher
and(PTransformMatcher matcher)
boolean
matches(AppliedPTransform<?,?,?> application)
default boolean
matchesDuringValidation(AppliedPTransform<?,?,?> application)
AnAppliedPTransform
matched by aPTransformMatcher
will be replaced during pipeline surgery, and is often expected to be gone in the new pipeline.default PTransformMatcher
or(PTransformMatcher matcher)
-
-
-
Method Detail
-
matches
boolean matches(AppliedPTransform<?,?,?> application)
-
matchesDuringValidation
default boolean matchesDuringValidation(AppliedPTransform<?,?,?> application)
AnAppliedPTransform
matched by aPTransformMatcher
will be replaced during pipeline surgery, and is often expected to be gone in the new pipeline. For theAppliedPTransform
that is expected to remain in the pipeline after surgery, the correspondingPTransformMatcher
should override this method, such that it will not be matched during the validation.
-
and
default PTransformMatcher and(PTransformMatcher matcher)
-
or
default PTransformMatcher or(PTransformMatcher matcher)
-
-