org.apache.flink.streaming.runtime.io

Class CachedBufferBlocker.CachedBufferOrEventSequence

java.lang.Object

org.apache.flink.streaming.runtime.io.CachedBufferBlocker.CachedBufferOrEventSequence

All Implemented Interfaces:

BufferOrEventSequence

Enclosing class:

CachedBufferBlocker

public static class CachedBufferBlocker.CachedBufferOrEventSequence
extends Object
implements BufferOrEventSequence

This class represents a sequence of cached buffers and events, created by the CachedBufferBlocker.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Cleans up all the resources held by the sequence.
org.apache.flink.runtime.io.network.partition.consumer.BufferOrEvent	getNext() Gets the next BufferOrEvent from the sequence, or null, if the sequence is exhausted.
void	open() Initializes the sequence for reading.
long	size() Gets the size of the sequence.

Methods inherited from class java.lang.Object

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

Method Detail

open

public void open()

Description copied from interface: BufferOrEventSequence

Initializes the sequence for reading.

Specified by:

open in interface BufferOrEventSequence

getNext

@Nullable
public org.apache.flink.runtime.io.network.partition.consumer.BufferOrEvent getNext()

Description copied from interface: BufferOrEventSequence

Gets the next BufferOrEvent from the sequence, or null, if the sequence is exhausted.

Specified by:

getNext in interface BufferOrEventSequence

Returns:

The next BufferOrEvent from the buffered sequence, or null (end of sequence).

cleanup

public void cleanup()

Description copied from interface: BufferOrEventSequence

Cleans up all the resources held by the sequence.

Specified by:

cleanup in interface BufferOrEventSequence

size

public long size()

Description copied from interface: BufferOrEventSequence

Gets the size of the sequence.

Specified by:

size in interface BufferOrEventSequence