See: Description
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. |