org.apache.beam.runners.fnexecution.state

Interface StateDelegator.Registration

Enclosing interface:

StateDelegator

public static interface StateDelegator.Registration

Allows callers to deregister from receiving further state requests.

Method Summary

Modifier and Type	Method and Description
void	abort() De-registers the handler for all future requests for state for the registered process bundle instruction id.
void	deregister() De-registers the handler for all future requests for state for the registered process bundle instruction id.

Method Detail

deregister

void deregister()

De-registers the handler for all future requests for state for the registered process bundle instruction id.

abort

void abort()

De-registers the handler for all future requests for state for the registered process bundle instruction id. Aborts all in-flight state requests.