Package | Description |
---|---|
org.apache.flink.state.api.output.operators | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.streamrecord | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.watermarkstatus | |
org.apache.flink.table.runtime.operators.multipleinput.input | |
org.apache.flink.table.runtime.operators.multipleinput.output | |
org.apache.flink.table.runtime.operators.wmassigners |
Modifier and Type | Method and Description |
---|---|
void |
StateBootstrapWrapperOperator.processWatermarkStatus(WatermarkStatus watermarkStatus) |
Modifier and Type | Method and Description |
---|---|
void |
Output.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
CountingOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
TimestampedCollector.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
AbstractInput.processWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
AbstractStreamOperator.processWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
Input.processWatermarkStatus(WatermarkStatus watermarkStatus)
Processes a
WatermarkStatus that arrived on this input of the MultipleInputStreamOperator . |
void |
AbstractStreamOperatorV2.processWatermarkStatus(WatermarkStatus watermarkStatus,
int inputId) |
void |
TwoInputStreamOperator.processWatermarkStatus1(WatermarkStatus watermarkStatus)
Processes a
WatermarkStatus that arrived on the first input of this two-input
operator. |
void |
AbstractStreamOperator.processWatermarkStatus1(WatermarkStatus watermarkStatus) |
void |
TwoInputStreamOperator.processWatermarkStatus2(WatermarkStatus watermarkStatus)
Processes a
WatermarkStatus that arrived on the second input of this two-input
operator. |
void |
AbstractStreamOperator.processWatermarkStatus2(WatermarkStatus watermarkStatus) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriterOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
PushingAsyncDataInput.DataOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
FinishedDataOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
Modifier and Type | Method and Description |
---|---|
void |
TimestampsAndWatermarksOperator.processWatermarkStatus(WatermarkStatus watermarkStatus)
Override the base implementation to completely ignore statuses propagated from upstream.
|
Modifier and Type | Method and Description |
---|---|
WatermarkStatus |
StreamElement.asWatermarkStatus()
Casts this element into a WatermarkStatus.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceOperatorStreamTask.AsyncDataOutputToOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
FinishedOnRestoreMainOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
FinishedOnRestoreInput.processWatermarkStatus(WatermarkStatus watermarkStatus) |
Modifier and Type | Field and Description |
---|---|
static WatermarkStatus |
WatermarkStatus.ACTIVE |
static WatermarkStatus |
WatermarkStatus.IDLE |
protected WatermarkStatus |
StatusWatermarkValve.InputChannelStatus.watermarkStatus |
Modifier and Type | Method and Description |
---|---|
void |
StatusWatermarkValve.inputWatermarkStatus(WatermarkStatus watermarkStatus,
int channelIndex,
PushingAsyncDataInput.DataOutput<?> output)
Feed a
WatermarkStatus into the valve. |
Modifier and Type | Method and Description |
---|---|
void |
SecondInputOfTwoInput.processWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
OneInput.processWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
FirstInputOfTwoInput.processWatermarkStatus(WatermarkStatus watermarkStatus) |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastingOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
CopyingSecondInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
FirstInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
SecondInputOfTwoInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
void |
OneInputStreamOperatorOutput.emitWatermarkStatus(WatermarkStatus watermarkStatus) |
Modifier and Type | Method and Description |
---|---|
void |
WatermarkAssignerOperator.processWatermarkStatus(WatermarkStatus watermarkStatus) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.