org.apache.flink.statefun.sdk.java

Class StatefulFunctions

java.lang.Object

org.apache.flink.statefun.sdk.java.StatefulFunctions

public class StatefulFunctions
extends java.lang.Object

A registry for multiple StatefulFunctions. A RequestReplyHandler can be created from the registry that understands how to dispatch invocation requests to the registered functions as well as encode side-effects (e.g., sending messages to other functions or updating values in storage) as the response.

Constructor Summary

Constructors

Constructor and Description
StatefulFunctions()

Method Summary

Modifier and Type	Method and Description
java.util.Map<TypeName,StatefulFunctionSpec>	functionSpecs()
RequestReplyHandler	requestReplyHandler() Creates a RequestReplyHandler that understands how to dispatch invocation requests to the registered functions as well as encode side-effects (e.g., sending messages to other functions or updating values in storage) as the response.
StatefulFunctions	withStatefulFunction(StatefulFunctionSpec.Builder builder) Registers a StatefulFunctionSpec builder, which will be used to build the function spec.
StatefulFunctions	withStatefulFunction(StatefulFunctionSpec spec) Registers a StatefulFunctionSpec.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatefulFunctions

public StatefulFunctions()

Method Detail

withStatefulFunction

public StatefulFunctions withStatefulFunction(StatefulFunctionSpec.Builder builder)

Registers a StatefulFunctionSpec builder, which will be used to build the function spec.

Parameters:

builder - a builder for the function spec to register.

Throws:

java.lang.IllegalArgumentException - if multiple StatefulFunctionSpec under the same TypeName have been registered.

withStatefulFunction

public StatefulFunctions withStatefulFunction(StatefulFunctionSpec spec)

Registers a StatefulFunctionSpec.

Parameters:

spec - the function spec to register.

Throws:

java.lang.IllegalArgumentException - if multiple StatefulFunctionSpec under the same TypeName have been registered.

functionSpecs

public java.util.Map<TypeName,StatefulFunctionSpec> functionSpecs()

Returns:

The registered StatefulFunctionSpecs.

requestReplyHandler

public RequestReplyHandler requestReplyHandler()

Creates a RequestReplyHandler that understands how to dispatch invocation requests to the registered functions as well as encode side-effects (e.g., sending messages to other functions or updating values in storage) as the response.

Returns:

a RequestReplyHandler for the registered functions.