Interface | Description |
---|---|
EpochAware |
Operators or UDF implements this method would be provided with an supplier that provides the
current rounds of the current element.
|
Class | Description |
---|---|
AbstractAllRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>> |
The base class for the all-round wrapper operators.
|
AllRoundOperatorWrapper<T> |
The operator wrapper implementation for all-round wrappers.
|
MultipleInputAllRoundWrapperOperator<OUT> |
All-round wrapper for the multiple-inputs operator.
|
OneInputAllRoundWrapperOperator<IN,OUT> |
All-round wrapper for the one-input operator.
|
TwoInputAllRoundWrapperOperator<IN1,IN2,OUT> |
All-round wrapper for the two-inputs operator.
|
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.