Class BundleCheckpointHandlers
java.lang.Object
org.apache.beam.runners.fnexecution.control.BundleCheckpointHandlers
Utility methods for creating
BundleCheckpointHandler
s.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
ABundleCheckpointHandler
which usesTimerInternals.TimerData
andValueState
to rescheduleBeamFnApi.DelayedBundleApplication
. -
Constructor Summary
Constructors -
Method Summary
-
Constructor Details
-
BundleCheckpointHandlers
public BundleCheckpointHandlers()
-