Class | Description |
---|---|
AbstractPerRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> |
The base class for all the per-round wrapper operators.
|
MultipleInputPerRoundWrapperOperator<OUT> |
Per-round wrapper for the multiple-inputs operator.
|
OneInputPerRoundWrapperOperator<IN,OUT> |
Per-round wrapper operator for the one-input operator.
|
PerRoundOperatorWrapper<T> |
The operator wrapper implementation for per-round wrappers.
|
TwoInputPerRoundWrapperOperator<IN1,IN2,OUT> |
Per-round wrapper for the two-inputs operator.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.