Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.runtime.state | |
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.util |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<E> |
RocksDBCachingPriorityQueueSet.iterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<T> |
InternalPriorityQueue.iterator()
Iterator over all elements, no order guaranteed.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<T> |
KeyGroupPartitionedPriorityQueue.iterator() |
CloseableIterator<T> |
AbstractHeapPriorityQueue.iterator()
Returns an iterator over the elements in this queue.
|
Modifier and Type | Class and Description |
---|---|
static class |
CloseableIterator.IteratorAdapter<E>
Adapter from
Iterator to CloseableIterator . |
Modifier and Type | Field and Description |
---|---|
static CloseableIterator<?> |
CloseableIterator.EMPTY_INSTANCE |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterator.adapterForIterator(Iterator<T> iterator) |
static <T> CloseableIterator<T> |
CloseableIterator.empty() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.