public class BroadcastVariableReceiverOperatorFactory<OUT> extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT> implements Serializable
BroadcastVariableReceiverOperator
.Constructor and Description |
---|
BroadcastVariableReceiverOperatorFactory(String[] broadcastNames,
org.apache.flink.api.common.typeinfo.TypeInformation<?>[] inTypes) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>> |
createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters) |
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader) |
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
public BroadcastVariableReceiverOperatorFactory(String[] broadcastNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] inTypes)
public <T extends org.apache.flink.streaming.api.operators.StreamOperator<OUT>> T createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT> parameters)
createStreamOperator
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>
public Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
getStreamOperatorClass
in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.