public interface BufferReceivedListener
Modifier and Type | Method and Description |
---|---|
void |
notifyBarrierReceived(CheckpointBarrier barrier,
InputChannelInfo channelInfo)
Invoked when an
InputChannel
receives a buffer with a CheckpointBarrier . |
void |
notifyBufferReceived(Buffer buffer,
InputChannelInfo channelInfo)
Called whenever an
InputChannel receives a non-barrier
buffer. |
void notifyBufferReceived(Buffer buffer, InputChannelInfo channelInfo) throws IOException
InputChannel
receives a non-barrier
buffer.
The listener is responsible for copying the buffer if it needs to outlive the invocation. It is guaranteed that no parallel processing of the buffer happens until this callback returns.
IOException
void notifyBarrierReceived(CheckpointBarrier barrier, InputChannelInfo channelInfo) throws IOException
InputChannel
receives a buffer with a CheckpointBarrier
. It is guaranteed that no parallel
processing of the buffer happens until this callback returns.IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.