org.apache.flink.streaming.runtime.io

Class BufferSpiller.SpilledBufferOrEventSequence

java.lang.Object

org.apache.flink.streaming.runtime.io.BufferSpiller.SpilledBufferOrEventSequence

All Implemented Interfaces:

BufferOrEventSequence

Enclosing class:

BufferSpiller

Deprecated.

@Deprecated
public static class BufferSpiller.SpilledBufferOrEventSequence
extends Object
implements BufferOrEventSequence

This class represents a sequence of spilled buffers and events, created by the BufferSpiller.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Deprecated. Cleans up all the resources held by the sequence.
BufferOrEvent	getNext() Deprecated. Gets the next BufferOrEvent from the sequence, or null, if the sequence is exhausted.
void	open() Deprecated. This method needs to be called before the first call to getNext().
long	size() Deprecated. 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()

Deprecated.

This method needs to be called before the first call to getNext(). Otherwise the results of getNext() are not predictable.

Specified by:

open in interface BufferOrEventSequence

getNext

public BufferOrEvent getNext()
                      throws IOException

Deprecated.

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).

Throws:

IOException

cleanup

public void cleanup()
             throws IOException

Deprecated.

Description copied from interface: BufferOrEventSequence

Cleans up all the resources held by the sequence.

Specified by:

cleanup in interface BufferOrEventSequence

Throws:

IOException

size

public long size()

Deprecated.

Description copied from interface: BufferOrEventSequence

Gets the size of the sequence.

Specified by:

size in interface BufferOrEventSequence