Uses of Interface
org.apache.paimon.utils.CloseableIterator

Packages that use CloseableIterator

Package	Description
org.apache.paimon.crosspartition
org.apache.paimon.io
org.apache.paimon.reader
org.apache.paimon.utils

Uses of CloseableIterator in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<BinaryRow>	GlobalIndexAssigner.endBoostrapWithoutEmit(boolean isEndInput)

Uses of CloseableIterator in org.apache.paimon.io

Methods in org.apache.paimon.io with parameters of type CloseableIterator

Modifier and Type	Method and Description
default void	FileWriter.write(CloseableIterator<T> records) Add records from CloseableIterator to this file writer.

Uses of CloseableIterator in org.apache.paimon.reader

Classes in org.apache.paimon.reader that implement CloseableIterator

Modifier and Type	Class and Description
class	RecordReaderIterator<T> Wrap a RecordReader as an CloseableIterator.

Methods in org.apache.paimon.reader that return CloseableIterator

Modifier and Type	Method and Description
default CloseableIterator<T>	RecordReader.toCloseableIterator() Convert this reader to a CloseableIterator.

Uses of CloseableIterator in org.apache.paimon.utils

Classes in org.apache.paimon.utils that implement CloseableIterator

Modifier and Type	Class and Description
static class	CloseableIterator.IteratorAdapter<E> Adapter from Iterator to CloseableIterator.

Fields in org.apache.paimon.utils declared as CloseableIterator

Modifier and Type	Field and Description
static CloseableIterator<?>	CloseableIterator.EMPTY_INSTANCE

Methods in org.apache.paimon.utils that return CloseableIterator

Modifier and Type	Method and Description
static <T> CloseableIterator<T>	CloseableIterator.adapterForIterator(Iterator<T> iterator)
static <T> CloseableIterator<T>	CloseableIterator.adapterForIterator(Iterator<T> iterator, AutoCloseable close)
static <T> CloseableIterator<T>	CloseableIterator.empty()
static <T> CloseableIterator<T>	CloseableIterator.flatten(CloseableIterator<T>... iterators)
static <T> CloseableIterator<T>	CloseableIterator.fromList(List<T> list, java.util.function.Consumer<T> closeNotConsumed)
static <E> CloseableIterator<E>	CloseableIterator.ofElement(E element, java.util.function.Consumer<E> closeIfNotConsumed)
static <T> CloseableIterator<T>	CloseableIterator.ofElements(java.util.function.Consumer<T> closeNotConsumed, T... elements)

Methods in org.apache.paimon.utils with parameters of type CloseableIterator

Modifier and Type	Method and Description
static <T> CloseableIterator<T>	CloseableIterator.flatten(CloseableIterator<T>... iterators)
static <V> List<V>	ObjectsFile.readFromIterator(CloseableIterator<InternalRow> inputIterator, ObjectSerializer<V> serializer, Filter<InternalRow> readFilter)

Constructor parameters in org.apache.paimon.utils with type arguments of type CloseableIterator

Constructor and Description
ObjectsCache(SegmentsCache<K> cache, ObjectSerializer<V> projectedSerializer, RowType formatSchema, FunctionWithIOException<K,Long> fileSizeFunction, BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader)