Uses of Interface
org.apache.flink.util.CloseableIterator

Packages that use CloseableIterator

Package	Description
org.apache.flink.connector.testframe.testsuites
org.apache.flink.contrib.streaming.state
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.io.disk
org.apache.flink.runtime.io.network.api.serialization
org.apache.flink.runtime.state
org.apache.flink.runtime.state.changelog
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.state.api.input
org.apache.flink.state.api.input.operator
org.apache.flink.state.changelog
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.operators.collect
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.client.gateway
org.apache.flink.table.gateway.service.result
org.apache.flink.util

Uses of CloseableIterator in org.apache.flink.connector.testframe.testsuites

Methods in org.apache.flink.connector.testframe.testsuites with parameters of type CloseableIterator

Modifier and Type	Method and Description
protected void	SourceTestSuiteBase.checkResultWithSemantic(CloseableIterator<T> resultIterator, List<List<T>> testData, CheckpointingMode semantic, Integer limit) Compare the test data with the result.

Uses of CloseableIterator in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<E>	RocksDBCachingPriorityQueueSet.iterator()

Uses of CloseableIterator in org.apache.flink.runtime.checkpoint.channel

Methods in org.apache.flink.runtime.checkpoint.channel with parameters of type CloseableIterator

Modifier and Type	Method and Description
void	ChannelStateWriterImpl.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> iterator)
void	ChannelStateWriter.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> data) Add in-flight buffers from the InputChannel.
void	ChannelStateWriter.NoOpChannelStateWriter.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> data)

Uses of CloseableIterator in org.apache.flink.runtime.io.disk

Classes in org.apache.flink.runtime.io.disk that implement CloseableIterator

Modifier and Type	Class and Description
class	FileBasedBufferIterator CloseableIterator of buffers over file content.

Uses of CloseableIterator in org.apache.flink.runtime.io.network.api.serialization

Methods in org.apache.flink.runtime.io.network.api.serialization that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<Buffer>	RecordDeserializer.getUnconsumedBuffer() Gets the unconsumed buffer which needs to be persisted in unaligned checkpoint scenario.
CloseableIterator<Buffer>	SpillingAdaptiveSpanningRecordDeserializer.getUnconsumedBuffer()

Uses of CloseableIterator in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<T>	InternalPriorityQueue.iterator() Iterator over all elements, no order guaranteed.

Uses of CloseableIterator in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<StateChange>	StateChangelogHandleStreamHandleReader.getChanges(ChangelogStateHandleStreamImpl handle)
CloseableIterator<StateChange>	StateChangelogHandleReader.getChanges(Handle handle)
CloseableIterator<StateChange>	StateChangelogHandleStreamHandleReader.StateChangeIterator.read(StreamStateHandle handle, long offset)

Uses of CloseableIterator in org.apache.flink.runtime.state.heap

Methods in org.apache.flink.runtime.state.heap that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<T>	AbstractHeapPriorityQueue.iterator() Returns an iterator over the elements in this queue.
CloseableIterator<T>	KeyGroupPartitionedPriorityQueue.iterator()

Uses of CloseableIterator in org.apache.flink.state.api.input

Classes in org.apache.flink.state.api.input that implement CloseableIterator

Modifier and Type	Class and Description
class	MultiStateKeyIterator<K> An iterator for reading all keys in a state backend across multiple partitioned states.

Uses of CloseableIterator in org.apache.flink.state.api.input.operator

Methods in org.apache.flink.state.api.input.operator that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<Tuple2<KEY,W>>	WindowReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx)
abstract CloseableIterator<Tuple2<KEY,N>>	StateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx)
CloseableIterator<Tuple2<KEY,VoidNamespace>>	KeyedStateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx)

Uses of CloseableIterator in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<T>	ChangelogKeyGroupedPriorityQueue.iterator()

Uses of CloseableIterator in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<T>	DataStream.collectAsync() Sets up the collection of the elements in this DataStream, and returns an iterator over the collected elements that can be used to retrieve elements once the job execution has started.
CloseableIterator<T>	DataStream.executeAndCollect() Triggers the distributed execution of the streaming dataflow and returns an iterator over the elements of the given DataStream.
CloseableIterator<T>	DataStream.executeAndCollect(String jobExecutionName) Triggers the distributed execution of the streaming dataflow and returns an iterator over the elements of the given DataStream.
CloseableIterator<T>	DataStream.Collector.getOutput() Returns an iterator over the collected elements.

Uses of CloseableIterator in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement CloseableIterator

Modifier and Type	Class and Description
class	CollectResultIterator<T> An iterator which iterates through the results of a query job.

Fields in org.apache.flink.streaming.api.operators.collect declared as CloseableIterator

Modifier and Type	Field and Description
CloseableIterator<E>	ClientAndIterator.iterator

Constructors in org.apache.flink.streaming.api.operators.collect with parameters of type CloseableIterator

Constructor and Description
ClientAndIterator(JobClient client, CloseableIterator<E> iterator)

Uses of CloseableIterator in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<Row>	TableResult.collect() Get the result contents as a closeable row iterator.

Uses of CloseableIterator in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal that return CloseableIterator

Modifier and Type	Method and Description
CloseableIterator<Row>	TableResultImpl.collect()
CloseableIterator<RowData>	TableResultInternal.collectInternal() Returns an iterator that returns the iterator with the internal row data type.
CloseableIterator<RowData>	TableResultImpl.collectInternal()
CloseableIterator<Row>	StaticResultProvider.toExternalIterator()
CloseableIterator<Row>	ResultProvider.toExternalIterator() Returns the select result as row iterator using external data types.
CloseableIterator<RowData>	StaticResultProvider.toInternalIterator()
CloseableIterator<RowData>	ResultProvider.toInternalIterator() Returns the select result as row iterator using internal data types.

Uses of CloseableIterator in org.apache.flink.table.client.gateway

Classes in org.apache.flink.table.client.gateway that implement CloseableIterator

Modifier and Type	Class and Description
class	StatementResult Wrapped results for the FetchResultsResponseBody.

Constructors in org.apache.flink.table.client.gateway with parameters of type CloseableIterator

Constructor and Description
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID)
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID, RowDataToStringConverter toStringConverter)

Uses of CloseableIterator in org.apache.flink.table.gateway.service.result

Constructors in org.apache.flink.table.gateway.service.result with parameters of type CloseableIterator

Constructor and Description
ResultStore(CloseableIterator<RowData> result, int maxBufferSize)

Uses of CloseableIterator in org.apache.flink.util

Classes in org.apache.flink.util that implement CloseableIterator

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

Fields in org.apache.flink.util declared as CloseableIterator

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

Methods in org.apache.flink.util 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, Consumer<T> closeNotConsumed)
static <E> CloseableIterator<E>	CloseableIterator.ofElement(E element, Consumer<E> closeIfNotConsumed)
static <T> CloseableIterator<T>	CloseableIterator.ofElements(Consumer<T> closeNotConsumed, T... elements)

Methods in org.apache.flink.util with parameters of type CloseableIterator

Modifier and Type	Method and Description
static <T> CloseableIterator<T>	CloseableIterator.flatten(CloseableIterator<T>... iterators)