Package org.apache.beam.runners.fnexecution.translation

Shared utilities for a Beam runner to translate portable pipelines.

See: Description

Interface Summary

Interface	Description
BatchSideInputHandlerFactory.SideInputGetter	Returns the value for the side input with the given PCollection id from the runner.

Class Summary

Class	Description
BatchSideInputHandlerFactory	StateRequestHandler that uses a BatchSideInputHandlerFactory.SideInputGetter to access side inputs.
PipelineTranslatorUtils	Utilities for pipeline translation.
StreamingSideInputHandlerFactory	StateRequestHandler that uses SideInputHandler to access the broadcast state that represents side inputs.

Package org.apache.beam.runners.fnexecution.translation Description

Shared utilities for a Beam runner to translate portable pipelines.