Class | Description |
---|---|
AbstractBroadcastWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> |
Base class for the broadcast wrapper operators.
|
BroadcastVariableReceiverOperator<OUT> |
The operator that process all broadcast inputs and stores them in
BroadcastContext . |
BroadcastVariableReceiverOperatorFactory<OUT> |
Factory class for
BroadcastVariableReceiverOperator . |
BroadcastWrapper<T> |
The operator wrapper for
AbstractBroadcastWrapperOperator . |
OneInputBroadcastWrapperOperator<IN,OUT> |
Wrapper for
OneInputStreamOperator . |
TwoInputBroadcastWrapperOperator<IN1,IN2,OUT> |
Wrapper for
TwoInputStreamOperator . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.