T
- The type encapsulated with the stream record.public static interface PushingAsyncDataInput.DataOutput<T>
Modifier and Type | Method and Description |
---|---|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitRecord(StreamRecord<T> streamRecord) |
void |
emitStreamStatus(StreamStatus streamStatus) |
void |
emitWatermark(Watermark watermark) |
void emitRecord(StreamRecord<T> streamRecord) throws Exception
Exception
void emitStreamStatus(StreamStatus streamStatus) throws Exception
Exception
void emitLatencyMarker(LatencyMarker latencyMarker) throws Exception
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.