org.apache.flink.statefun.flink.state.processor.operator

Class StateBootstrapFunctionRegistry

java.lang.Object

org.apache.flink.statefun.flink.state.processor.operator.StateBootstrapFunctionRegistry

All Implemented Interfaces:

java.io.Serializable

public final class StateBootstrapFunctionRegistry
extends java.lang.Object
implements java.io.Serializable

A registry that handles StateBootstrapFunctionProvider registrations.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StateBootstrapFunctionRegistry()

Method Summary

Modifier and Type	Method and Description
int	numRegistrations() Returns number of registrations.
void	register(FunctionType functionType, StateBootstrapFunctionProvider stateBootstrapFunctionProvider) Registers a StateBootstrapFunctionProvider.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StateBootstrapFunctionRegistry

public StateBootstrapFunctionRegistry()

Method Detail

register

public void register(FunctionType functionType,
                     StateBootstrapFunctionProvider stateBootstrapFunctionProvider)

Registers a StateBootstrapFunctionProvider.

Parameters:

functionType - the type of the function that is being bootstrapped.

stateBootstrapFunctionProvider - provider of the bootstrap function.

numRegistrations

public int numRegistrations()

Returns number of registrations.

Returns:

number of registrations.