Package org.apache.beam.runners.fnexecution.control

Class BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler<T>

java.lang.Object
org.apache.beam.runners.fnexecution.control.BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler<T>
All Implemented Interfaces:
BundleCheckpointHandler
Enclosing class:
BundleCheckpointHandlers
public static class BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler<T> extends Object implements BundleCheckpointHandler
A BundleCheckpointHandler which uses TimerInternals.TimerData and ValueState to reschedule BeamFnApi.DelayedBundleApplication.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    SDF_PREFIX
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    StateAndTimerBundleCheckpointHandler(org.apache.beam.runners.core.TimerInternalsFactory<T> timerInternalsFactory, org.apache.beam.runners.core.StateInternalsFactory<T> stateInternalsFactory, Coder<WindowedValue<T>> residualCoder, Coder windowCoder)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static boolean
    isSdfTimer(String timerId)
    A helper function to help check whether the given timer is the timer which is set for rescheduling BeamFnApi.DelayedBundleApplication.
    void
    onCheckpoint(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • StateAndTimerBundleCheckpointHandler

      public StateAndTimerBundleCheckpointHandler(org.apache.beam.runners.core.TimerInternalsFactory<T> timerInternalsFactory, org.apache.beam.runners.core.StateInternalsFactory<T> stateInternalsFactory, Coder<WindowedValue<T>> residualCoder, Coder windowCoder)

  • Method Details

    • isSdfTimer

      public static boolean isSdfTimer(String timerId)
      A helper function to help check whether the given timer is the timer which is set for rescheduling BeamFnApi.DelayedBundleApplication.

    • onCheckpoint

      public void onCheckpoint(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
      Specified by:
      onCheckpoint in interface BundleCheckpointHandler