Package org.apache.iceberg.io

Interface CloseableIterable<T>

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, java.lang.Iterable<T>

All Known Implementing Classes:

AvroIterable, CloseableIterable.ConcatCloseableIterable, ManifestReader, ParallelIterable, ParquetIterable, ParquetReader, SortedMerge, VectorizedParquetReader, VectorizedTableScanIterable

public interface CloseableIterable<T>
extends java.lang.Iterable<T>, java.io.Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	CloseableIterable.ConcatCloseableIterable<E>

Method Summary

Modifier and Type	Method	Description
static <E> CloseableIterable<E>	combine(java.lang.Iterable<E> iterable, java.io.Closeable closeable)
static <E> CloseableIterable<E>	concat(java.lang.Iterable<CloseableIterable<E>> iterable)
static <E> CloseableIterable<E>	empty()
static <E> CloseableIterable<E>	filter(CloseableIterable<E> iterable, java.util.function.Predicate<E> pred)
CloseableIterator<T>	iterator()	Returns an closeable iterator over elements of type T.
static <I,O> CloseableIterable<O>	transform(CloseableIterable<I> iterable, java.util.function.Function<I,O> transform)
static <E> CloseableIterable<E>	withNoopClose(E entry)
static <E> CloseableIterable<E>	withNoopClose(java.lang.Iterable<E> iterable)

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

iterator

CloseableIterator<T> iterator()

Returns an closeable iterator over elements of type T.

Specified by:

iterator in interface java.lang.Iterable<T>

Returns:

an CloseableIterator.

withNoopClose

static <E> CloseableIterable<E> withNoopClose(E entry)

withNoopClose

static <E> CloseableIterable<E> withNoopClose(java.lang.Iterable<E> iterable)

empty

static <E> CloseableIterable<E> empty()

combine

static <E> CloseableIterable<E> combine(java.lang.Iterable<E> iterable,
                                        java.io.Closeable closeable)

filter

static <E> CloseableIterable<E> filter(CloseableIterable<E> iterable,
                                       java.util.function.Predicate<E> pred)

transform

static <I,O> CloseableIterable<O> transform(CloseableIterable<I> iterable,
                                                  java.util.function.Function<I,O> transform)

concat

static <E> CloseableIterable<E> concat(java.lang.Iterable<CloseableIterable<E>> iterable)