org.apache.flink.statefun.flink.core

Class StatefulFunctionsUniverse

java.lang.Object

org.apache.flink.statefun.flink.core.StatefulFunctionsUniverse

All Implemented Interfaces:

ExtensionModule.Binder, ExtensionResolver, FlinkIoModule.Binder, StatefulFunctionModule.Binder

public final class StatefulFunctionsUniverse
extends java.lang.Object
implements StatefulFunctionModule.Binder, FlinkIoModule.Binder, ExtensionModule.Binder, ExtensionResolver

Constructor Summary

Constructors

Constructor and Description
StatefulFunctionsUniverse(MessageFactoryKey messageFactoryKey)

Method Summary

Modifier and Type	Method and Description
<T> void	bindEgress(EgressSpec<T> spec) Binds an EgressSpec to the Stateful Functions application.
<T> void	bindExtension(TypeName typeName, T extension)
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> ingressIdentifier, Router<T> router) Binds a Router for a given ingress to the Stateful Functions application.
void	bindSinkProvider(EgressType type, SinkProvider provider)
void	bindSourceProvider(IngressType type, SourceProvider provider)
java.util.Map<EgressIdentifier<?>,EgressSpec<?>>	egress()
java.util.Map<FunctionType,StatefulFunctionProvider>	functions()
java.util.Map<TypeName,java.lang.Object>	getExtensions()
java.util.Map<IngressIdentifier<?>,IngressSpec<?>>	ingress()
MessageFactoryKey	messageFactoryKey()
java.util.Map<java.lang.String,StatefulFunctionProvider>	namespaceFunctions()
<T> T	resolveExtension(TypeName typeName, java.lang.Class<T> extensionClass)
java.util.Map<IngressIdentifier<?>,java.util.List<Router<?>>>	routers()
java.util.Map<EgressType,SinkProvider>	sinks()
java.util.Map<IngressType,SourceProvider>	sources()
StaticallyRegisteredTypes	types()

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulFunctionsUniverse

public StatefulFunctionsUniverse(MessageFactoryKey messageFactoryKey)

Method Detail

bindIngress

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

Description copied from interface: StatefulFunctionModule.Binder

Binds an IngressSpec to the Stateful Functions application.

Specified by:

bindIngress in interface StatefulFunctionModule.Binder

Type Parameters:

T - the output type of the ingress.

Parameters:

spec - the IngressSpec to bind.

bindIngressRouter

public <T> void bindIngressRouter(IngressIdentifier<T> ingressIdentifier,
                                  Router<T> router)

Description copied from interface: StatefulFunctionModule.Binder

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

Specified by:

bindIngressRouter in interface StatefulFunctionModule.Binder

Type Parameters:

T - the type of messages that is being routed.

Parameters:

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

router - the router to bind.

bindEgress

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

Description copied from interface: StatefulFunctionModule.Binder

Binds an EgressSpec to the Stateful Functions application.

Specified by:

bindEgress in interface StatefulFunctionModule.Binder

Type Parameters:

T - the type of inputs that the egress consumes.

Parameters:

spec - the EgressSpec to bind.

bindFunctionProvider

public void bindFunctionProvider(FunctionType functionType,
                                 StatefulFunctionProvider provider)

Description copied from interface: StatefulFunctionModule.Binder

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

Specified by:

bindFunctionProvider in interface StatefulFunctionModule.Binder

Parameters:

functionType - the type of functions that the StatefulFunctionProvider provides.

provider - the provider to bind.

bindFunctionProvider

public void bindFunctionProvider(FunctionTypeNamespaceMatcher namespaceMatcher,
                                 StatefulFunctionProvider provider)

Description copied from interface: StatefulFunctionModule.Binder

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 StatefulFunctionModule.Binder.bindFunctionProvider(FunctionType, StatefulFunctionProvider), that provider would be used instead.

Specified by:

bindFunctionProvider in interface StatefulFunctionModule.Binder

Parameters:

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

provider - the provider to bind.

bindSourceProvider

public void bindSourceProvider(IngressType type,
                               SourceProvider provider)

Specified by:

bindSourceProvider in interface FlinkIoModule.Binder

bindSinkProvider

public void bindSinkProvider(EgressType type,
                             SinkProvider provider)

Specified by:

bindSinkProvider in interface FlinkIoModule.Binder

bindExtension

public <T> void bindExtension(TypeName typeName,
                              T extension)

Specified by:

bindExtension in interface ExtensionModule.Binder

resolveExtension

public <T> T resolveExtension(TypeName typeName,
                              java.lang.Class<T> extensionClass)

Specified by:

resolveExtension in interface ExtensionResolver

ingress

public java.util.Map<IngressIdentifier<?>,IngressSpec<?>> ingress()

egress

public java.util.Map<EgressIdentifier<?>,EgressSpec<?>> egress()

routers

public java.util.Map<IngressIdentifier<?>,java.util.List<Router<?>>> routers()

functions

public java.util.Map<FunctionType,StatefulFunctionProvider> functions()

namespaceFunctions

public java.util.Map<java.lang.String,StatefulFunctionProvider> namespaceFunctions()

sources

public java.util.Map<IngressType,SourceProvider> sources()

sinks

public java.util.Map<EgressType,SinkProvider> sinks()

getExtensions

public java.util.Map<TypeName,java.lang.Object> getExtensions()

types

public StaticallyRegisteredTypes types()

messageFactoryKey

public MessageFactoryKey messageFactoryKey()