Modifier and Type | Method and Description |
---|---|
void |
DirectedOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
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) |
void |
AbstractStreamOperator.LatencyGauge.reportLatency(LatencyMarker marker,
boolean isSink) |
protected void |
StreamSink.reportOrForwardLatencyMarker(LatencyMarker maker) |
protected void |
AbstractStreamOperator.reportOrForwardLatencyMarker(LatencyMarker marker) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriterOutput.emitLatencyMarker(LatencyMarker latencyMarker) |
Modifier and Type | Method and Description |
---|---|
LatencyMarker |
StreamElement.asLatencyMarker()
Casts this element into a LatencyMarker.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.