@DefaultAnnotation(value=org.checkerframework.checker.nullness.qual.NonNull.class)
See: Description
| Interface | Description |
|---|---|
| ExecutableStage |
A combination of PTransforms that can be executed within a single SDK harness.
|
| PipelineNode |
A graph node which contains some pipeline element.
|
| ProtoOverrides.TransformReplacement |
A Function that takes a transform and the existing components and returns the new composite
PTransform and additional components.
|
| Class | Description |
|---|---|
| FusedPipeline |
A
RunnerApi.Pipeline which has been separated into collections of executable components. |
| GreedyPipelineFuser |
Fuses a
RunnerApi.Pipeline into some set of single-environment executable transforms. |
| GreedyStageFuser |
A factory class which produces an
ExecutableStage by attempting to fuse all available
PCollections when it is constructed. |
| ImmutableExecutableStage |
An
ExecutableStage which is constructed with all of its initial state. |
| Networks |
Static utility methods for
Network instances that are directed. |
| Networks.TypeSafeNodeFunction<NodeT,T extends NodeT> |
An abstract class that can be extended to apply a function in a type safe manner.
|
| PipelineNode.PCollectionNode |
A
PipelineNode which contains a RunnerApi.PCollection. |
| PipelineNode.PTransformNode |
A
PipelineNode which contains a RunnerApi.PTransform. |
| PipelineValidator |
Validates well-formedness of a pipeline.
|
| ProjectionPushdownOptimizer | |
| ProtoOverrides |
A way to apply a Proto-based
PTransformOverride. |
| QueryablePipeline |
A
RunnerApi.Pipeline which has additional methods to relate nodes in the graph relative to each
other. |
| SideInputReference |
A reference to a side input.
|
| SplittableParDoExpander |
A set of transform replacements for expanding a splittable ParDo into various sub components.
|
| TimerReference |
Contains references to components relevant for runners during execution for timers.
|
| TrivialNativeTransformExpander |
TrivialNativeTransformExpander is used to replace transforms with known URNs with their native
equivalent.
|
| UserStateReference |
A reference to user state.
|