org.apache.flink.statefun.sdk.spi

Interface StatefulFunctionModule.Binder

All Known Implementing Classes:

StatefulFunctionsUniverse

Enclosing interface:

StatefulFunctionModule

public static interface StatefulFunctionModule.Binder

A StatefulFunctionModule.Binder binds ingresses, egresses, routers, and functions to a Stateful Functions application.

Method Summary

Modifier and Type	Method and Description
<T> void	bindEgress(EgressSpec<T> spec) Binds an EgressSpec to the Stateful Functions application.
void	bindFunctionProvider(FunctionTypeNamespaceMatcher namespaceMatcher, StatefulFunctionProvider provider) Binds a StatefulFunctionProvider to the Stateful Functions application for all functions under the specified namespace.
void	bindFunctionProvider(FunctionType functionType, StatefulFunctionProvider provider) Binds a StatefulFunctionProvider to the Stateful Functions application for a specific FunctionType.
<T> void	bindIngress(IngressSpec<T> spec) Binds an IngressSpec to the Stateful Functions application.
<T> void	bindIngressRouter(IngressIdentifier<T> id, Router<T> router) Binds a Router for a given ingress to the Stateful Functions application.

Method Detail

bindIngress

<T> void bindIngress(IngressSpec<T> spec)

Binds an IngressSpec to the Stateful Functions application.

Type Parameters:

T - the output type of the ingress.

Parameters:

spec - the IngressSpec to bind.

bindEgress

<T> void bindEgress(EgressSpec<T> spec)

Binds an EgressSpec to the Stateful Functions application.

Type Parameters:

T - the type of inputs that the egress consumes.

Parameters:

spec - the EgressSpec to bind.

bindFunctionProvider

void bindFunctionProvider(FunctionType functionType,
                          StatefulFunctionProvider provider)

Binds a StatefulFunctionProvider to the Stateful Functions application for a specific FunctionType.

Parameters:

functionType - the type of functions that the StatefulFunctionProvider provides.

provider - the provider to bind.

bindFunctionProvider

void bindFunctionProvider(FunctionTypeNamespaceMatcher namespaceMatcher,
                          StatefulFunctionProvider provider)

Binds a StatefulFunctionProvider to the Stateful Functions application for all functions under the specified namespace. If a provider was bound for a specific function type using bindFunctionProvider(FunctionType, StatefulFunctionProvider), that provider would be used instead.

Parameters:

namespaceMatcher - matcher for the target namespace of functions that the StatefulFunctionProvider provides.

provider - the provider to bind.

bindIngressRouter

<T> void bindIngressRouter(IngressIdentifier<T> id,
                           Router<T> router)

Binds a Router for a given ingress to the Stateful Functions application.

Type Parameters:

T - the type of messages that is being routed.

Parameters:

id - the id of the ingress to bind the router to.

router - the router to bind.