Package pipelinex contains utilities for manipulating Beam proto pipelines. The utilities generally uses shallow copies and do not mutate their inputs.
Bounded returns true iff all PCollections are bounded.
ContainerImages returns the set of container images used in the given pipeline.
Normalize recomputes derivative information in the pipeline, such as roots and input/output for composite transforms. It also ensures that unique names are so and topologically sorts each subtransform list.
ShallowCloneFunctionSpec makes a shallow copy of the given FunctionSpec.
ShallowClonePTransform makes a shallow copy of the given PTransform.
ShallowCloneParDoPayload makes a shallow copy of the given ParDoPayload.
ShallowCloneSideInput makes a shallow copy of the given SideInput.
TopologicalSort returns a topologically sorted list of the given ids, generally from the same scope/composite. Assumes acyclic graph.
TrimCoders returns the transitive closure of the given coders ids.
Update merges a pipeline with the given components, which may add, replace or delete its values. It returns the merged pipeline. The input is not modified.