T
- The output type@Internal public abstract class AbstractDataOutput<T> extends Object implements PushingAsyncDataInput.DataOutput<T>
Modifier and Type | Field and Description |
---|---|
protected Object |
lock |
protected StreamStatusMaintainer |
streamStatusMaintainer
The maintainer toggles the current stream status.
|
Constructor and Description |
---|
AbstractDataOutput(StreamStatusMaintainer streamStatusMaintainer,
Object lock) |
Modifier and Type | Method and Description |
---|---|
void |
emitStreamStatus(StreamStatus streamStatus) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
emitLatencyMarker, emitRecord, emitWatermark
protected final StreamStatusMaintainer streamStatusMaintainer
protected final Object lock
public AbstractDataOutput(StreamStatusMaintainer streamStatusMaintainer, Object lock)
public void emitStreamStatus(StreamStatus streamStatus)
emitStreamStatus
in interface PushingAsyncDataInput.DataOutput<T>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.