Package | Description |
---|---|
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.heap |
This package contains the classes for key/value state backends that store the state on the JVM
heap as objects.
|
org.apache.flink.streaming.api.operators.collect | |
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.planner.sinks | |
org.apache.flink.table.sinks | |
org.apache.flink.util |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<E> |
RocksDBCachingPriorityQueueSet.iterator() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedBufferIterator
CloseableIterator of buffers over file content. |
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() |
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> |
AbstractHeapPriorityQueue.iterator()
Returns an iterator over the elements in this queue.
|
CloseableIterator<T> |
KeyGroupPartitionedPriorityQueue.iterator() |
Modifier and Type | Class and Description |
---|---|
class |
CollectResultIterator<T>
An iterator which iterates through the results of a query job.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
TableResult.collect()
Get the result contents as a closeable row iterator.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
SelectTableSink.getResultIterator()
Returns the select result as row iterator.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
SelectTableSinkBase.getResultIterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Row> |
BatchSelectTableSink.getResultIterator() |
CloseableIterator<Row> |
StreamSelectTableSink.getResultIterator() |
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.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) |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterator.flatten(CloseableIterator<T>... iterators) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.