Package org.apache.beam.runners.core.construction

Provides utilities for Beam runner authors, prior to execution.

See: Description

Interface Summary

Interface	Description
CoderTranslator<T extends Coder<?>>	An interface that translates coders to components and back.
PTransforms.TransformPayloadTranslator<T extends PTransform<?,?>>	A translator consumes a PTransform application and produces the appropriate FunctionSpec for a distinguished or primitive transform within the Beam runner API.

Class Summary

Class	Description
Coders	Converts to and from Beam Runner API representations of Coders.
DeduplicatedFlattenFactory<T>	A PTransformOverrideFactory that will apply a flatten where no element appears in the input PCollectionList more than once.
EmptyFlattenAsCreateFactory<T>	A PTransformOverrideFactory that provides an empty Create to replace a Flatten.PCollections that takes no input PCollections.
ForwardingPTransform<InputT extends PInput,OutputT extends POutput>	A base class for implementing PTransform overrides, which behave identically to the delegate transform but with overridden methods.
PCollections	Utility methods for translating PCollections to and from Runner API protos.
PrimitiveCreate<T>	An implementation of Create that returns a primitive PCollection.
PrimitiveCreate.Factory<T>	A PTransformOverrideFactory that creates instances of PrimitiveCreate.
PTransformMatchers	A PTransformMatcher that matches PTransforms based on the class of the transform.
PTransformReplacements
PTransforms	Utilities for converting PTransforms to and from Runner API protocol buffers.
ReplacementOutputs	Utility methods for creating PTransformOverrideFactory.ReplacementOutput for known styles of POutput.
SingleInputOutputOverrideFactory<InputT extends PValue,OutputT extends PValue,TransformT extends PTransform<InputT,OutputT>>	A PTransformOverrideFactory which consumes from a PValue and produces a PValue.
Triggers	Utilities for working with Triggers.
UnboundedReadFromBoundedSource<T>	PTransform that converts a BoundedSource as an UnboundedSource.
UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter<T>	A BoundedSource to UnboundedSource adapter.
UnconsumedReads	Utilities for ensuring that all Read PTransforms are consumed by some PTransform.
UnsupportedOverrideFactory<InputT extends PInput,OutputT extends POutput,TransformT extends PTransform<InputT,OutputT>>	A PTransformOverrideFactory that throws an exception when a call to UnsupportedOverrideFactory.getReplacementTransform(AppliedPTransform) is made.
WindowingStrategies	Utilities for working with WindowingStrategies.

Package org.apache.beam.runners.core.construction Description

Provides utilities for Beam runner authors, prior to execution.