org.apache.flink.statefun.flink.core.functions

Class FunctionGroupDispatchFactory

java.lang.Object

org.apache.flink.statefun.flink.core.functions.FunctionGroupDispatchFactory

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<Message,Message>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<Message>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<Message>

public final class FunctionGroupDispatchFactory
extends java.lang.Object
implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<Message,Message>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<Message>

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<T extends org.apache.flink.streaming.api.operators.StreamOperator<Message>> T	createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Message> 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType

Constructor Detail

FunctionGroupDispatchFactory

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

Method Detail

setMailboxExecutor

public void setMailboxExecutor(org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor)

Specified by:

setMailboxExecutor in interface org.apache.flink.streaming.api.operators.YieldingOperatorFactory<Message>

createStreamOperator

public <T extends org.apache.flink.streaming.api.operators.StreamOperator<Message>> T createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Message> streamOperatorParameters)

Specified by:

createStreamOperator in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<Message>

setChainingStrategy

public void setChainingStrategy(org.apache.flink.streaming.api.operators.ChainingStrategy chainingStrategy)

Specified by:

setChainingStrategy in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<Message>

getChainingStrategy

public org.apache.flink.streaming.api.operators.ChainingStrategy getChainingStrategy()

Specified by:

getChainingStrategy in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<Message>

getStreamOperatorClass

public java.lang.Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(java.lang.ClassLoader classLoader)

Specified by:

getStreamOperatorClass in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<Message>