Package | Description |
---|---|
org.apache.flink.statefun.flink.core.feedback | |
org.apache.flink.statefun.flink.core.translation |
Constructor and Description |
---|
FeedbackSinkOperator(FeedbackKey<V> key,
java.util.function.LongFunction<V> barrierSentinelSupplier) |
FeedbackUnionOperatorFactory(StatefulFunctionsConfig configuration,
FeedbackKey<E> feedbackKey,
SerializableFunction<E,java.util.OptionalLong> isBarrierMessage,
SerializableFunction<E,?> keySelector) |
Constructor and Description |
---|
EmbeddedTranslator(StatefulFunctionsConfig config,
FeedbackKey<Message> feedbackKey) |
FlinkUniverse(FeedbackKey<Message> feedbackKey,
StatefulFunctionsConfig configuration,
StatefulFunctionsUniverse universe) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.