org.apache.beam.runners.fnexecution.state

Interface StateDelegator

All Known Implementing Classes:

GrpcStateService

public interface StateDelegator

The StateDelegator is able to delegate BeamFnApi.StateRequests to a set of registered handlers. Any request for an unregistered process bundle instruction id is automatically failed.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	StateDelegator.Registration Allows callers to deregister from receiving further state requests.

Method Summary

Modifier and Type	Method and Description
StateDelegator.Registration	registerForProcessBundleInstructionId(java.lang.String processBundleInstructionId, StateRequestHandler handler) Registers the supplied handler for the given process bundle instruction id for all BeamFnApi.StateRequests with a matching id.

Method Detail

registerForProcessBundleInstructionId

StateDelegator.Registration registerForProcessBundleInstructionId(java.lang.String processBundleInstructionId,
                                                                  StateRequestHandler handler)

Registers the supplied handler for the given process bundle instruction id for all BeamFnApi.StateRequests with a matching id. A handle is returned which allows one to deregister from this StateDelegator.