void |
Output.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
AbstractStreamOperator.CountingOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
void |
OneInputStreamOperator.processLatencyMarker(LatencyMarker latencyMarker) |
void |
AbstractStreamOperator.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 |
StreamSink.reportOrForwardLatencyMarker(LatencyMarker marker) |
protected void |
AbstractStreamOperator.reportOrForwardLatencyMarker(LatencyMarker marker) |