public static class SourceOperatorStreamTask.AsyncDataOutputToOutput<T> extends Object implements PushingAsyncDataInput.DataOutput<T>
PushingAsyncDataInput.DataOutput
that wraps a specific Output
.Constructor and Description |
---|
AsyncDataOutputToOutput(Output<StreamRecord<T>> output,
InternalSourceReaderMetricGroup metricGroup,
WatermarkGauge inputWatermarkGauge) |
Modifier and Type | Method and Description |
---|---|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitRecord(StreamRecord<T> streamRecord) |
void |
emitRecordAttributes(RecordAttributes recordAttributes) |
void |
emitWatermark(Watermark watermark) |
void |
emitWatermarkStatus(WatermarkStatus watermarkStatus) |
public AsyncDataOutputToOutput(Output<StreamRecord<T>> output, InternalSourceReaderMetricGroup metricGroup, @Nullable WatermarkGauge inputWatermarkGauge)
public void emitRecord(StreamRecord<T> streamRecord)
emitRecord
in interface PushingAsyncDataInput.DataOutput<T>
public void emitLatencyMarker(LatencyMarker latencyMarker)
emitLatencyMarker
in interface PushingAsyncDataInput.DataOutput<T>
public void emitRecordAttributes(RecordAttributes recordAttributes)
emitRecordAttributes
in interface PushingAsyncDataInput.DataOutput<T>
public void emitWatermark(Watermark watermark)
emitWatermark
in interface PushingAsyncDataInput.DataOutput<T>
public void emitWatermarkStatus(WatermarkStatus watermarkStatus) throws Exception
emitWatermarkStatus
in interface PushingAsyncDataInput.DataOutput<T>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.