Package | Description |
---|---|
org.apache.flink.statefun.flink.datastream |
Modifier and Type | Method and Description |
---|---|
static StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.builder(java.lang.String pipelineName)
Creates a
StatefulFunctionDataStreamBuilder . |
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withConfiguration(StatefulFunctionsConfig configuration)
Set a stateful function configuration.
|
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withDataStreamAsIngress(org.apache.flink.streaming.api.datastream.DataStream<RoutableMessage> ingress)
Adds an ingress of incoming messages.
|
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withEgressId(EgressIdentifier<?> egressId)
Registers an
EgressIdentifier . |
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withFunctionProvider(FunctionType functionType,
SerializableStatefulFunctionProvider provider)
Adds a function provider to this builder
|
StatefulFunctionDataStreamBuilder |
StatefulFunctionDataStreamBuilder.withRequestReplyRemoteFunction(StatefulFunctionBuilder builder)
Adds a remote RequestReply type of function provider to this builder.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.