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 . |
Modifier and Type | Method and Description |
---|---|
static StatefulFunctionsUniverse |
StatefulFunctionsUniverses.get(java.lang.ClassLoader classLoader,
StatefulFunctionsConfig configuration) |
StatefulFunctionsUniverse |
StatefulFunctionsUniverseProvider.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.
|
Constructor and Description |
---|
FeedbackUnionOperatorFactory(StatefulFunctionsConfig configuration,
FeedbackKey<E> feedbackKey,
SerializableFunction<E,java.util.OptionalLong> isBarrierMessage,
SerializableFunction<E,?> keySelector) |
Constructor and Description |
---|
FunctionGroupDispatchFactory(StatefulFunctionsConfig configuration,
java.util.Map<EgressIdentifier<?>,org.apache.flink.util.OutputTag<java.lang.Object>> sideOutputs) |
Modifier and Type | Method and Description |
---|---|
StatefulFunctionsUniverse |
Modules.createStatefulFunctionsUniverse(StatefulFunctionsConfig configuration) |
Constructor and Description |
---|
FlinkUniverse(StatefulFunctionsUniverse universe,
StatefulFunctionsConfig configuration) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.