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

Packages that use CloseableIterable

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.util

Uses of CloseableIterable in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return CloseableIterable

Modifier and Type	Method and Description
CloseableIterable<KeyGroupStatePartitionStreamProvider>	StreamOperatorStateContext.rawKeyedStateInputs() Returns an iterable to obtain input streams for previously stored keyed state partitions that are assigned to this operator.
protected CloseableIterable<KeyGroupStatePartitionStreamProvider>	StreamTaskStateInitializerImpl.rawKeyedStateInputs(Iterator<StateObjectCollection<KeyedStateHandle>> restoreStateAlternatives)
CloseableIterable<StatePartitionStreamProvider>	StreamOperatorStateContext.rawOperatorStateInputs() Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to this stream operator.
protected CloseableIterable<StatePartitionStreamProvider>	StreamTaskStateInitializerImpl.rawOperatorStateInputs(Iterator<StateObjectCollection<OperatorStateHandle>> restoreStateAlternatives)

Uses of CloseableIterable in org.apache.flink.util

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

Modifier and Type	Class and Description
static class	CloseableIterable.Empty<T> Empty iterator.

Methods in org.apache.flink.util that return CloseableIterable

Modifier and Type	Method and Description
static <T> CloseableIterable<T>	CloseableIterable.empty() Returns an empty iterator.