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 java.lang.Object
implements BundleCheckpointHandler

A BundleCheckpointHandler which uses TimerInternals.TimerData and ValueState to reschedule BeamFnApi.DelayedBundleApplication.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SDF_PREFIX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static boolean	isSdfTimer(java.lang.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 Detail

SDF_PREFIX

public static final java.lang.String SDF_PREFIX

See Also:

Constant Field Values

Constructor Detail

StateAndTimerBundleCheckpointHandler

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

Method Detail

isSdfTimer

public static boolean isSdfTimer(java.lang.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