org.apache.beam.runners.fnexecution.control

Interface BundleCheckpointHandler

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 and Description
void	onCheckpoint(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)

Method Detail

onCheckpoint

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