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

package org.apache.beam.runners.fnexecution.translation

Shared utilities for a Beam runner to translate portable pipelines.

Class	Description
BatchSideInputHandlerFactory	StateRequestHandler that uses a BatchSideInputHandlerFactory.SideInputGetter to access side inputs.
BatchSideInputHandlerFactory.SideInputGetter	Returns the value for the side input with the given PCollection id from the runner.
PipelineTranslatorUtils	Utilities for pipeline translation.
StreamingSideInputHandlerFactory	StateRequestHandler that uses SideInputHandler to access the broadcast state that represents side inputs.