org.apache.flink.statefun.flink.datastream

Class StatefulFunctionDataStreamBuilder

java.lang.Object

org.apache.flink.statefun.flink.datastream.StatefulFunctionDataStreamBuilder

public final class StatefulFunctionDataStreamBuilder
extends java.lang.Object

Builder for a Stateful Function Application.

This builder allows defining all the aspects of a stateful function application. define input streams as ingresses, define function providers and egress ids.

Method Summary

Modifier and Type	Method and Description
StatefulFunctionEgressStreams	build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) Adds Stateful Functions operators into the topology.
static StatefulFunctionDataStreamBuilder	builder(java.lang.String pipelineName) Creates a StatefulFunctionDataStreamBuilder.
StatefulFunctionDataStreamBuilder	withConfiguration(StatefulFunctionsConfig configuration) Set a stateful function configuration.
StatefulFunctionDataStreamBuilder	withDataStreamAsIngress(org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage> ingress) Adds an ingress of incoming messages.
StatefulFunctionDataStreamBuilder	withEgressId(EgressIdentifier<?> egressId) Registers an EgressIdentifier.
StatefulFunctionDataStreamBuilder	withFunctionProvider(FunctionType functionType, SerializableStatefulFunctionProvider provider) Adds a function provider to this builder
StatefulFunctionDataStreamBuilder	withRequestReplyRemoteFunction(RequestReplyFunctionBuilder builder) Adds a remote RequestReply type of function provider to this builder.

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static StatefulFunctionDataStreamBuilder builder(java.lang.String pipelineName)

Creates a StatefulFunctionDataStreamBuilder.

withDataStreamAsIngress

public StatefulFunctionDataStreamBuilder withDataStreamAsIngress(org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage> ingress)

Adds an ingress of incoming messages.

Parameters:

ingress - an incoming stream of messages.

Returns:

this builder.

withFunctionProvider

public StatefulFunctionDataStreamBuilder withFunctionProvider(FunctionType functionType,
                                                              SerializableStatefulFunctionProvider provider)

Adds a function provider to this builder

Parameters:

functionType - the type of the function that this provider providers.

provider - the stateful function provider.

Returns:

this builder.

withRequestReplyRemoteFunction

public StatefulFunctionDataStreamBuilder withRequestReplyRemoteFunction(RequestReplyFunctionBuilder builder)

Adds a remote RequestReply type of function provider to this builder.

Parameters:

builder - an already configured RequestReplyFunctionBuilder.

Returns:

this builder.

withEgressId

public StatefulFunctionDataStreamBuilder withEgressId(EgressIdentifier<?> egressId)

Registers an EgressIdentifier.

See StatefulFunctionEgressStreams.getDataStreamForEgressId(EgressIdentifier).

Parameters:

egressId - an ingress id

Returns:

this builder.

withConfiguration

public StatefulFunctionDataStreamBuilder withConfiguration(StatefulFunctionsConfig configuration)

Set a stateful function configuration.

Parameters:

configuration - the stateful function configuration to set.

Returns:

this builder.

build

public StatefulFunctionEgressStreams build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Adds Stateful Functions operators into the topology.

Parameters:

env - the stream execution environment.