Modifier and Type | Class and Description |
---|---|
class |
AbstractWrapperOperator<T>
The base class of all the wrapper operators.
|
class |
ReplayOperator<T>
Replays the data received in the round 0 in the following round.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAllRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>>
The base class for the all-round wrapper operators.
|
class |
MultipleInputAllRoundWrapperOperator<OUT>
All-round wrapper for the multiple-inputs operator.
|
class |
OneInputAllRoundWrapperOperator<IN,OUT>
All-round wrapper for the one-input operator.
|
class |
TwoInputAllRoundWrapperOperator<IN1,IN2,OUT>
All-round wrapper for the two-inputs operator.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractPerRoundWrapperOperator<T,S extends org.apache.flink.streaming.api.operators.StreamOperator<T>>
The base class for all the per-round wrapper operators.
|
class |
MultipleInputPerRoundWrapperOperator<OUT>
Per-round wrapper for the multiple-inputs operator.
|
class |
OneInputPerRoundWrapperOperator<IN,OUT>
Per-round wrapper operator for the one-input operator.
|
class |
TwoInputPerRoundWrapperOperator<IN1,IN2,OUT>
Per-round wrapper for the two-inputs operator.
|
Modifier and Type | Method and Description |
---|---|
static OperatorEpochWatermarkTracker |
OperatorEpochWatermarkTrackerFactory.create(org.apache.flink.streaming.api.graph.StreamConfig streamConfig,
org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask,
OperatorEpochWatermarkTrackerListener progressTrackerListener) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.