public class FinishedDataOutput<IN> extends Object implements PushingAsyncDataInput.DataOutput<IN>
PushingAsyncDataInput.DataOutput
which is used by StreamOneInputProcessor
once an DataInputStatus.END_OF_DATA
is received.Constructor and Description |
---|
FinishedDataOutput() |
Modifier and Type | Method and Description |
---|---|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitRecord(StreamRecord<IN> streamRecord) |
void |
emitWatermark(Watermark watermark) |
void |
emitWatermarkStatus(WatermarkStatus watermarkStatus) |
public void emitRecord(StreamRecord<IN> streamRecord) throws Exception
emitRecord
in interface PushingAsyncDataInput.DataOutput<IN>
Exception
public void emitWatermark(Watermark watermark) throws Exception
emitWatermark
in interface PushingAsyncDataInput.DataOutput<IN>
Exception
public void emitWatermarkStatus(WatermarkStatus watermarkStatus) throws Exception
emitWatermarkStatus
in interface PushingAsyncDataInput.DataOutput<IN>
Exception
public void emitLatencyMarker(LatencyMarker latencyMarker) throws Exception
emitLatencyMarker
in interface PushingAsyncDataInput.DataOutput<IN>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.