Modifier and Type | Class and Description |
---|---|
class |
KeyValueDataFileRecordReader
RecordReader for reading KeyValue data files. |
class |
RowDataFileRecordReader
Reads
RowData from data files. |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
KeyValueFileReaderFactory.createRecordReader(long schemaId,
String fileName,
int level) |
Modifier and Type | Class and Description |
---|---|
class |
DropDeleteReader
|
Modifier and Type | Method and Description |
---|---|
static RecordReader<KeyValue> |
MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections,
boolean dropDelete,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunction<KeyValue> mergeFunction) |
static RecordReader<KeyValue> |
MergeTreeReaders.readerForRun(SortedRun run,
KeyValueFileReaderFactory readerFactory) |
static RecordReader<KeyValue> |
MergeTreeReaders.readerForSection(List<SortedRun> section,
KeyValueFileReaderFactory readerFactory,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunctionWrapper<KeyValue> mergeFunctionWrapper) |
Constructor and Description |
---|
DropDeleteReader(RecordReader<KeyValue> reader) |
Modifier and Type | Class and Description |
---|---|
class |
ConcatRecordReader<T>
This reader is to concatenate a list of
RecordReader s and read them sequentially. |
class |
SortMergeReader<T>
This reader is to read a list of
RecordReader , which is already sorted by key and
sequence number, and perform a sort merge algorithm. |
Modifier and Type | Method and Description |
---|---|
static <R> RecordReader<R> |
ConcatRecordReader.create(List<ConcatRecordReader.ReaderSupplier<R>> readers) |
RecordReader<T> |
ConcatRecordReader.ReaderSupplier.get() |
Constructor and Description |
---|
SortMergeReader(List<RecordReader<KeyValue>> readers,
Comparator<org.apache.flink.table.data.RowData> userKeyComparator,
MergeFunctionWrapper<T> mergeFunctionWrapper) |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
KeyValueFileStoreRead.createReader(DataSplit split) |
RecordReader<T> |
FileStoreRead.createReader(DataSplit split)
Create a
RecordReader from split. |
RecordReader<org.apache.flink.table.data.RowData> |
AppendOnlyFileStoreRead.createReader(DataSplit split) |
Modifier and Type | Class and Description |
---|---|
class |
IteratorRecordReader<T>
Wrap a
Iterator as an RecordReader . |
Modifier and Type | Method and Description |
---|---|
static <L,R> RecordReader<R> |
RecordReaderUtils.transform(RecordReader<L> fromReader,
java.util.function.Function<L,R> function)
|
Modifier and Type | Method and Description |
---|---|
static <T> void |
RecordReaderUtils.forEachRemaining(RecordReader<T> reader,
java.util.function.Consumer<? super T> action)
Performs the given action for each remaining element in
RecordReader until all
elements have been processed or the action throws an exception. |
static <L,R> RecordReader<R> |
RecordReaderUtils.transform(RecordReader<L> fromReader,
java.util.function.Function<L,R> function)
|
Constructor and Description |
---|
RecordReaderIterator(RecordReader<T> reader) |
Modifier and Type | Method and Description |
---|---|
default RecordReader<org.apache.flink.table.data.RowData> |
TableRead.createReader(List<Split> splits) |
RecordReader<org.apache.flink.table.data.RowData> |
TableRead.createReader(Split split) |
RecordReader<org.apache.flink.table.data.RowData> |
KeyValueTableRead.createReader(Split split) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.