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.streamrecord | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.util | |
org.apache.flink.table.runtime.operators.multipleinput.input | |
org.apache.flink.table.runtime.operators.multipleinput.output | |
org.apache.flink.table.runtime.operators.sink |
Modifier and Type | Method and Description |
---|---|
void |
StateBootstrapWrapperOperator.processLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
void |
Output.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
TimestampedCollector.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
CountingOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
AbstractStreamOperator.processLatencyMarker(LatencyMarker latencyMarker) |
void |
Input.processLatencyMarker(LatencyMarker latencyMarker)
Processes a
LatencyMarker that arrived on the first input of this two-input operator. |
void |
AbstractInput.processLatencyMarker(LatencyMarker latencyMarker) |
void |
TwoInputStreamOperator.processLatencyMarker1(LatencyMarker latencyMarker)
Processes a
LatencyMarker that arrived on the first input of this two-input operator. |
void |
AbstractStreamOperator.processLatencyMarker1(LatencyMarker latencyMarker) |
void |
TwoInputStreamOperator.processLatencyMarker2(LatencyMarker latencyMarker)
Processes a
LatencyMarker that arrived on the second input of this two-input
operator. |
void |
AbstractStreamOperator.processLatencyMarker2(LatencyMarker latencyMarker) |
protected void |
AbstractStreamOperatorV2.reportOrForwardLatencyMarker(LatencyMarker marker) |
protected void |
AbstractStreamOperator.reportOrForwardLatencyMarker(LatencyMarker marker) |
protected void |
StreamSink.reportOrForwardLatencyMarker(LatencyMarker marker) |
Modifier and Type | Method and Description |
---|---|
void |
FinishedDataOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
PushingAsyncDataInput.DataOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
RecordWriterOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
LatencyMarker |
StreamElement.asLatencyMarker()
Casts this element into a LatencyMarker.
|
Modifier and Type | Method and Description |
---|---|
void |
FinishedOnRestoreMainOperatorOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
SourceOperatorStreamTask.AsyncDataOutputToOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
FinishedOnRestoreInput.processLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
void |
LatencyStats.reportLatency(LatencyMarker marker) |
Modifier and Type | Method and Description |
---|---|
void |
FirstInputOfTwoInput.processLatencyMarker(LatencyMarker latencyMarker) |
void |
OneInput.processLatencyMarker(LatencyMarker latencyMarker) |
void |
SecondInputOfTwoInput.processLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
void |
CopyingSecondInputOfTwoInputStreamOperatorOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
BroadcastingOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
FirstInputOfTwoInputStreamOperatorOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
SecondInputOfTwoInputStreamOperatorOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
OneInputStreamOperatorOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
protected void |
SinkOperator.reportOrForwardLatencyMarker(LatencyMarker marker) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.