Modifier and Type | Class and Description |
---|---|
class |
AbstractFileRecordIterator<V>
Abstract
RecordReader.RecordIterator implementation for schema evolution. |
Modifier and Type | Method and Description |
---|---|
RecordReader.RecordIterator<KeyValue> |
KeyValueDataFileRecordReader.readBatch() |
RecordReader.RecordIterator<org.apache.flink.table.data.RowData> |
RowDataFileRecordReader.readBatch() |
Modifier and Type | Method and Description |
---|---|
RecordReader.RecordIterator<KeyValue> |
DropDeleteReader.readBatch() |
Modifier and Type | Method and Description |
---|---|
RecordReader.RecordIterator<T> |
SortMergeReader.readBatch() |
RecordReader.RecordIterator<T> |
ConcatRecordReader.readBatch() |
Modifier and Type | Method and Description |
---|---|
RecordReader.RecordIterator<T> |
IteratorRecordReader.readBatch() |
RecordReader.RecordIterator<T> |
RecordReader.readBatch()
Reads one batch.
|
static <L,R> RecordReader.RecordIterator<R> |
RecordReaderUtils.transform(RecordReader.RecordIterator<L> fromIterator,
java.util.function.Function<L,R> function)
Returns an iterator that applies
function to each element of fromIterator . |
Modifier and Type | Method and Description |
---|---|
static <L,R> RecordReader.RecordIterator<R> |
RecordReaderUtils.transform(RecordReader.RecordIterator<L> fromIterator,
java.util.function.Function<L,R> function)
Returns an iterator that applies
function to each element of fromIterator . |
Modifier and Type | Class and Description |
---|---|
class |
ResetRowKindRecordIterator
A
RecordReader.RecordIterator which resets RowKind.INSERT to previous key value. |
class |
ValueContentRowDataRecordIterator
A
RecordReader.RecordIterator mapping a KeyValue to its value. |
class |
ValueCountRowDataRecordIterator
|
Modifier and Type | Method and Description |
---|---|
protected abstract RecordReader.RecordIterator<org.apache.flink.table.data.RowData> |
KeyValueTableRead.rowDataRecordIteratorFromKv(RecordReader.RecordIterator<KeyValue> kvRecordIterator) |
Modifier and Type | Method and Description |
---|---|
protected abstract RecordReader.RecordIterator<org.apache.flink.table.data.RowData> |
KeyValueTableRead.rowDataRecordIteratorFromKv(RecordReader.RecordIterator<KeyValue> kvRecordIterator) |
Constructor and Description |
---|
ResetRowKindRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator) |
ValueContentRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator) |
ValueCountRowDataRecordIterator(RecordReader.RecordIterator<KeyValue> kvIterator) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.