org.apache.flink.runtime.io.network.partition.consumer

Class InputChannel.BufferAndAvailability

java.lang.Object

org.apache.flink.runtime.io.network.partition.consumer.InputChannel.BufferAndAvailability

Enclosing class:

InputChannel

public static final class InputChannel.BufferAndAvailability
extends Object

A combination of a Buffer and a flag indicating availability of further buffers, and the backlog length indicating how many non-event buffers are available in the subpartition.

Constructor Summary

Constructors

Constructor and Description
BufferAndAvailability(Buffer buffer, boolean moreAvailable, int buffersInBacklog)

Method Summary

Modifier and Type	Method and Description
Buffer	buffer()
int	buffersInBacklog()
boolean	moreAvailable()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferAndAvailability

public BufferAndAvailability(Buffer buffer,
                             boolean moreAvailable,
                             int buffersInBacklog)

Method Detail

buffer

public Buffer buffer()

moreAvailable

public boolean moreAvailable()

buffersInBacklog

public int buffersInBacklog()