org.apache.flink.runtime.operators.util

Interface CloseableInputProvider<E>

All Superinterfaces:

AutoCloseable, Closeable

All Known Subinterfaces:

PushSorter<E>, Sorter<E>

All Known Implementing Classes:

BinaryExternalSorter, ExternalSorter, SimpleCloseableInputProvider, TempBarrier

public interface CloseableInputProvider<E>
extends Closeable

Utility interface for a provider of an input that can be closed.

Method Summary

Modifier and Type	Method and Description
MutableObjectIterator<E>	getIterator() Gets the iterator over this input.

Methods inherited from interface java.io.Closeable

close

Method Detail

getIterator

MutableObjectIterator<E> getIterator()
                              throws InterruptedException,
                                     IOException

Gets the iterator over this input.

Returns:

The iterator provided by this iterator provider.

Throws:

InterruptedException

IOException