@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class) @Internal
Package org.apache.beam.sdk.runners
For internal use only; no backwards compatibility guarantees.
Internals for use by runners.
-
Interface Summary Interface Description PipelineRunnerRegistrar For internal use only; no backwards-compatibility guarantees.PTransformMatcher For internal use only; no backwards-compatibility guarantees.PTransformOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>> For internal use only; no backwards-compatibility guarantees. -
Class Summary Class Description AppliedPTransform<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<? super InputT,OutputT>> For internal use only; no backwards-compatibility guarantees.PTransformOverride For internal use only; no backwards-compatibility guarantees.PTransformOverrideFactory.PTransformReplacement<InputT extends PInput,OutputT extends POutput> APTransform
that replaces anAppliedPTransform
, and the input required to do so.PTransformOverrideFactory.ReplacementOutput A mapping between originalTaggedPValue
outputs and their replacements.TransformHierarchy For internal use only; no backwards-compatibility guarantees.