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

Interface BootstrapDataRouterProvider<T>

Type Parameters:

T - data type of elements in the bootstrap dataset being routed.

All Superinterfaces:

java.io.Serializable

public interface BootstrapDataRouterProvider<T>
extends java.io.Serializable

Provides instances of a Router to route bootstrap data to StateBootstrapFunctions.

Method Summary

Modifier and Type	Method and Description
Router<T>	provide() Creates a Router instance.

Method Detail

provide

@Nonnull
Router<T> provide()

Creates a Router instance.

Returns:

a router for bootstrap data