org.apache.beam.sdk.runners

Interface PTransformMatcher

@Internal
public interface PTransformMatcher

For internal use only; no backwards-compatibility guarantees.

Matches applications of PTransforms.

Method Summary

Modifier and Type	Method and Description
default PTransformMatcher	and(PTransformMatcher matcher)
boolean	matches(AppliedPTransform<?,?,?> application)
default boolean	matchesDuringValidation(AppliedPTransform<?,?,?> application) An AppliedPTransform matched by a PTransformMatcher 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)

An AppliedPTransform matched by a PTransformMatcher will be replaced during pipeline surgery, and is often expected to be gone in the new pipeline. For the AppliedPTransform that is expected to remain in the pipeline after surgery, the corresponding PTransformMatcher 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)