org.apache.flink.runtime.io.network

Interface NetworkSequenceViewReader

public interface NetworkSequenceViewReader

Simple wrapper for the partition readerQueue iterator, which increments a sequence number for each returned buffer and remembers the receiver ID.

Method Summary

Modifier and Type	Method and Description
void	addCredit(int creditDeltas) The credits from consumer are added in incremental way.
Throwable	getFailureCause()
InputChannel.BufferAndAvailability	getNextBuffer()
InputChannelID	getReceiverId()
int	getSequenceNumber()
boolean	isAvailable() Checks whether this reader is available or not.
boolean	isRegisteredAsAvailable()
boolean	isReleased()
void	releaseAllResources()
void	requestSubpartitionView(ResultPartitionProvider partitionProvider, ResultPartitionID resultPartitionId, int subPartitionIndex)
void	resumeConsumption() Resumes data consumption after an exactly once checkpoint.
void	setRegisteredAsAvailable(boolean isRegisteredAvailable) Updates the value to indicate whether the reader is enqueued in the pipeline or not.

Method Detail

requestSubpartitionView

void requestSubpartitionView(ResultPartitionProvider partitionProvider,
                             ResultPartitionID resultPartitionId,
                             int subPartitionIndex)
                      throws IOException

Throws:

IOException

getNextBuffer

InputChannel.BufferAndAvailability getNextBuffer()
                                          throws IOException

Throws:

IOException

addCredit

void addCredit(int creditDeltas)

The credits from consumer are added in incremental way.

Parameters:

creditDeltas - The credit deltas

resumeConsumption

void resumeConsumption()

Resumes data consumption after an exactly once checkpoint.

isAvailable

boolean isAvailable()

Checks whether this reader is available or not.

Returns:

True if the reader is available.

isRegisteredAsAvailable

boolean isRegisteredAsAvailable()

setRegisteredAsAvailable

void setRegisteredAsAvailable(boolean isRegisteredAvailable)

Updates the value to indicate whether the reader is enqueued in the pipeline or not.

Parameters:

isRegisteredAvailable - True if this reader is already enqueued in the pipeline.

isReleased

boolean isReleased()

releaseAllResources

void releaseAllResources()
                  throws IOException

Throws:

IOException

getFailureCause

Throwable getFailureCause()

getReceiverId

InputChannelID getReceiverId()

getSequenceNumber

int getSequenceNumber()