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

Interface BundleCheckpointHandler

All Known Implementing Classes:

BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler

public interface BundleCheckpointHandler

A handler which is invoked when the SDK returns BeamFnApi.DelayedBundleApplications as part of the bundle completion.

These bundle applications must be resumed otherwise data loss will occur.

See breaking the fusion barrier for further details.

Method Summary

Modifier and Type	Method	Description
void	onCheckpoint(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)

Method Details

onCheckpoint

void onCheckpoint(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)