public static class SourceOperatorStreamTask.AsyncDataOutputToOutput<T> extends AbstractDataOutput<T>
PushingAsyncDataInput.DataOutput
that wraps a specific Output
.streamStatusMaintainer
Constructor and Description |
---|
AsyncDataOutputToOutput(Output<StreamRecord<T>> output,
StreamStatusMaintainer streamStatusMaintainer,
Counter numRecordsOut,
WatermarkGauge inputWatermarkGauge) |
Modifier and Type | Method and Description |
---|---|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitRecord(StreamRecord<T> streamRecord) |
void |
emitWatermark(Watermark watermark) |
emitStreamStatus
public AsyncDataOutputToOutput(Output<StreamRecord<T>> output, StreamStatusMaintainer streamStatusMaintainer, Counter numRecordsOut, @Nullable WatermarkGauge inputWatermarkGauge)
public void emitRecord(StreamRecord<T> streamRecord)
public void emitLatencyMarker(LatencyMarker latencyMarker)
public void emitWatermark(Watermark watermark)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.