Package org.apache.beam.runners.fnexecution.splittabledofn

Utilities for a Beam runner to interact with a remotely running splittable DoFn.

See: Description

Class Summary

Class	Description
SDFFeederViaStateAndTimers<InputT,RestrictionT>	Helper class for feeding element/restricton pairs into a PTransformTranslation.SPLITTABLE_PROCESS_ELEMENTS_URN transform, implementing checkpointing only, by using state and timers for storing the last element/restriction pair, similarly to SplittableParDoViaKeyedWorkItems.ProcessFn but in a portable fashion.

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

Utilities for a Beam runner to interact with a remotely running splittable DoFn.