Uses of Class
org.apache.flink.statefun.flink.core.StatefulFunctionsConfig

Packages that use StatefulFunctionsConfig

Package	Description
org.apache.flink.statefun.flink.core
org.apache.flink.statefun.flink.core.feedback
org.apache.flink.statefun.flink.core.functions
org.apache.flink.statefun.flink.core.spi
org.apache.flink.statefun.flink.core.translation
org.apache.flink.statefun.flink.datastream

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.core

Methods in org.apache.flink.statefun.flink.core that return StatefulFunctionsConfig

Modifier and Type	Method and Description
static StatefulFunctionsConfig	StatefulFunctionsConfig.fromEnvironment(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) Creates a new StatefulFunctionsConfig based on the default configurations in the current environment set via the flink-conf.yaml.
static StatefulFunctionsConfig	StatefulFunctionsConfig.fromFlinkConfiguration(org.apache.flink.configuration.Configuration flinkConfiguration)

Methods in org.apache.flink.statefun.flink.core with parameters of type StatefulFunctionsConfig

Modifier and Type	Method and Description
StatefulFunctionsUniverse	StatefulFunctionsUniverseProvider.get(java.lang.ClassLoader classLoader, StatefulFunctionsConfig configuration)
static StatefulFunctionsUniverse	StatefulFunctionsUniverses.get(java.lang.ClassLoader classLoader, StatefulFunctionsConfig configuration)
static void	StatefulFunctionsJob.main(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, StatefulFunctionsConfig stateFunConfig) The main entry point for executing a stateful functions application.

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.core.feedback

Constructors in org.apache.flink.statefun.flink.core.feedback with parameters of type StatefulFunctionsConfig

Constructor and Description
FeedbackUnionOperatorFactory(StatefulFunctionsConfig configuration, FeedbackKey<E> feedbackKey, SerializableFunction<E,java.util.OptionalLong> isBarrierMessage, SerializableFunction<E,?> keySelector)

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.core.functions

Constructors in org.apache.flink.statefun.flink.core.functions with parameters of type StatefulFunctionsConfig

Constructor and Description
FunctionGroupDispatchFactory(StatefulFunctionsConfig configuration, java.util.Map<EgressIdentifier<?>,org.apache.flink.util.OutputTag<java.lang.Object>> sideOutputs)

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.core.spi

Methods in org.apache.flink.statefun.flink.core.spi with parameters of type StatefulFunctionsConfig

Modifier and Type	Method and Description
static Modules	Modules.loadFromClassPath(StatefulFunctionsConfig configuration)

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.core.translation

Constructors in org.apache.flink.statefun.flink.core.translation with parameters of type StatefulFunctionsConfig

Constructor and Description
EmbeddedTranslator(StatefulFunctionsConfig config, FeedbackKey<Message> feedbackKey)
FlinkUniverse(FeedbackKey<Message> feedbackKey, StatefulFunctionsConfig configuration, StatefulFunctionsUniverse universe)

Uses of StatefulFunctionsConfig in org.apache.flink.statefun.flink.datastream

Methods in org.apache.flink.statefun.flink.datastream with parameters of type StatefulFunctionsConfig

Modifier and Type	Method and Description
StatefulFunctionDataStreamBuilder	StatefulFunctionDataStreamBuilder.withConfiguration(StatefulFunctionsConfig configuration) Set a stateful function configuration.