public final class FeedbackUnionOperatorFactory<E>
extends java.lang.Object
implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<E,E>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<E>
Constructor and Description |
---|
FeedbackUnionOperatorFactory(StatefulFunctionsConfig configuration,
FeedbackKey<E> feedbackKey,
SerializableFunction<E,java.util.OptionalLong> isBarrierMessage,
SerializableFunction<E,?> keySelector) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<E>> |
createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<E> streamOperatorParameters) |
org.apache.flink.streaming.api.operators.ChainingStrategy |
getChainingStrategy() |
java.lang.Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> |
getStreamOperatorClass(java.lang.ClassLoader classLoader) |
void |
setChainingStrategy(org.apache.flink.streaming.api.operators.ChainingStrategy chainingStrategy) |
void |
setMailboxExecutor(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor) |
public FeedbackUnionOperatorFactory(StatefulFunctionsConfig configuration, FeedbackKey<E> feedbackKey, SerializableFunction<E,java.util.OptionalLong> isBarrierMessage, SerializableFunction<E,?> keySelector)
public <T extends org.apache.flink.streaming.api.operators.StreamOperator<E>> T createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<E> streamOperatorParameters)
createStreamOperator
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<E>
public void setMailboxExecutor(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor)
setMailboxExecutor
in interface org.apache.flink.streaming.api.operators.YieldingOperatorFactory<E>
public void setChainingStrategy(org.apache.flink.streaming.api.operators.ChainingStrategy chainingStrategy)
setChainingStrategy
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<E>
public org.apache.flink.streaming.api.operators.ChainingStrategy getChainingStrategy()
getChainingStrategy
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<E>
public java.lang.Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(java.lang.ClassLoader classLoader)
getStreamOperatorClass
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<E>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.