Uses of Interface
org.apache.paimon.reader.RecordReader

Packages that use RecordReader

Package	Description
org.apache.paimon.crosspartition
org.apache.paimon.deletionvectors
org.apache.paimon.flink.compact.changelog.format
org.apache.paimon.flink.lookup
org.apache.paimon.format
org.apache.paimon.format.avro
org.apache.paimon.io
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.operation
org.apache.paimon.reader
org.apache.paimon.table.source
org.apache.paimon.table.source.splitread
org.apache.paimon.table.system
org.apache.paimon.utils

Uses of RecordReader in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	IndexBootstrap.bootstrap(int numAssigners, int assignId)

Uses of RecordReader in org.apache.paimon.deletionvectors

Classes in org.apache.paimon.deletionvectors that implement RecordReader

Modifier and Type	Class and Description
class	ApplyDeletionVectorReader A RecordReader which apply DeletionVector to filter record.

Methods in org.apache.paimon.deletionvectors that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	ApplyDeletionVectorReader.reader()

Constructors in org.apache.paimon.deletionvectors with parameters of type RecordReader

Constructor and Description
ApplyDeletionVectorReader(RecordReader<InternalRow> reader, DeletionVector deletionVector)

Uses of RecordReader in org.apache.paimon.flink.compact.changelog.format

Methods in org.apache.paimon.flink.compact.changelog.format that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	CompactedChangelogFormatReaderFactory.createReader(FormatReaderFactory.Context context)

Uses of RecordReader in org.apache.paimon.flink.lookup

Methods in org.apache.paimon.flink.lookup that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	IncrementalCompactDiffSplitRead.createReader(DataSplit split)
RecordReader<InternalRow>	LookupStreamingReader.nextBatch(boolean useParallelism)
RecordReader<InternalRow>	LookupCompactDiffRead.reader(Split split)

Uses of RecordReader in org.apache.paimon.format

Methods in org.apache.paimon.format that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	FormatReaderFactory.createReader(FormatReaderFactory.Context context)

Uses of RecordReader in org.apache.paimon.format.avro

Methods in org.apache.paimon.format.avro that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	AvroBulkFormat.createReader(FormatReaderFactory.Context context)

Uses of RecordReader in org.apache.paimon.io

Classes in org.apache.paimon.io that implement RecordReader

Modifier and Type	Class and Description
class	FileRecordReader Reads InternalRow from data files.
class	KeyValueDataFileRecordReader RecordReader for reading KeyValue data files.

Methods in org.apache.paimon.io that return RecordReader

Modifier and Type	Method and Description
RecordReader<KeyValue>	KeyValueFileReaderFactory.createRecordReader(DataFileMeta file)
RecordReader<T>	FileReaderFactory.createRecordReader(DataFileMeta file)
RecordReader<KeyValue>	KeyValueFileReaderFactory.createRecordReader(long schemaId, String fileName, long fileSize, int level)
static RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism)
static <EXTRA> RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism, java.util.function.Function<Split,EXTRA> extraFunction, java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow)

Method parameters in org.apache.paimon.io with type arguments of type RecordReader

Modifier and Type	Method and Description
static RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism)
static <EXTRA> RecordReader<InternalRow>	SplitsParallelReadUtil.parallelExecute(RowType projectedType, FunctionWithIOException<Split,RecordReader<InternalRow>> readBuilder, List<Split> splits, int pageSize, int parallelism, java.util.function.Function<Split,EXTRA> extraFunction, java.util.function.BiFunction<InternalRow,EXTRA,InternalRow> addExtraToRow)

Constructors in org.apache.paimon.io with parameters of type RecordReader

Constructor and Description
KeyValueDataFileRecordReader(RecordReader<InternalRow> reader, RowType keyType, RowType valueType, int level)

Uses of RecordReader in org.apache.paimon.mergetree

Classes in org.apache.paimon.mergetree that implement RecordReader

Modifier and Type	Class and Description
class	DropDeleteReader A RecordReader which drops KeyValue that does not meet RowKind.isAdd() from the wrapped reader.

Methods in org.apache.paimon.mergetree that return RecordReader

Modifier and Type	Method and Description
<T> RecordReader<T>	MergeSorter.mergeSort(List<SizedReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
<T> RecordReader<T>	MergeSorter.mergeSortNoSpill(List<? extends ReaderSupplier<KeyValue>> lazyReaders, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunction)
static <T> RecordReader<T>	MergeTreeReaders.readerForMergeTree(List<List<SortedRun>> sections, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)
static <T> RecordReader<T>	MergeTreeReaders.readerForSection(List<SortedRun> section, FileReaderFactory<KeyValue> readerFactory, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, MergeSorter mergeSorter)

Constructors in org.apache.paimon.mergetree with parameters of type RecordReader

Constructor and Description
DropDeleteReader(RecordReader<KeyValue> reader)

Constructor parameters in org.apache.paimon.mergetree with type arguments of type RecordReader

Constructor and Description

LookupLevels(Levels levels, Comparator<InternalRow> keyComparator, RowType keyType, LookupLevels.ValueProcessor<T> valueProcessor, IOFunction<DataFileMeta,RecordReader<KeyValue>> fileReaderFactory, java.util.function.Function<String,File> localFileFactory, LookupStoreFactory lookupStoreFactory, java.util.function.Function<Long,BloomFilter.Builder> bfGenerator, org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> lookupFileCache)

Uses of RecordReader in org.apache.paimon.mergetree.compact

Subinterfaces of RecordReader in org.apache.paimon.mergetree.compact

Modifier and Type	Interface and Description
interface	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.

Classes in org.apache.paimon.mergetree.compact that implement RecordReader

Modifier and Type	Class and Description
class	ConcatRecordReader<T> This reader is to concatenate a list of RecordReaders and read them sequentially.
class	SortMergeReaderWithLoserTree<T> SortMergeReader implemented with loser-tree.
class	SortMergeReaderWithMinHeap<T> SortMergeReader implemented with min-heap.

Methods in org.apache.paimon.mergetree.compact that return RecordReader

Modifier and Type	Method and Description
static <R> RecordReader<R>	ConcatRecordReader.create(List<? extends ReaderSupplier<R>> readers)
static <R> RecordReader<R>	ConcatRecordReader.create(ReaderSupplier<R> reader1, ReaderSupplier<R> reader2)
protected <T> RecordReader<T>	MergeTreeCompactRewriter.readerForMergeTree(List<List<SortedRun>> sections, MergeFunctionWrapper<T> mergeFunctionWrapper)

Method parameters in org.apache.paimon.mergetree.compact with type arguments of type RecordReader

Modifier and Type	Method and Description
static <T> SortMergeReader<T>	SortMergeReader.createSortMergeReader(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper, CoreOptions.SortEngine sortEngine)

Constructor parameters in org.apache.paimon.mergetree.compact with type arguments of type RecordReader

Constructor and Description
LoserTree(List<RecordReader<T>> nextBatchReaders, Comparator<T> firstComparator, Comparator<T> secondComparator)
SortMergeReaderWithLoserTree(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper)
SortMergeReaderWithMinHeap(List<RecordReader<KeyValue>> readers, Comparator<InternalRow> userKeyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionWrapper<T> mergeFunctionWrapper)

Uses of RecordReader in org.apache.paimon.operation

Classes in org.apache.paimon.operation that implement RecordReader

Modifier and Type	Class and Description
class	ReverseReader A RecordReader which reverses the RowKind of the KeyValue from RowKind.INSERT to RowKind.DELETE read from the wrapped reader.

Methods in org.apache.paimon.operation that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	DefaultValueAssigner.assignFieldsDefaultValue(RecordReader<InternalRow> reader) assign default value for column which value is null.
RecordReader<KeyValue>	MergeFileSplitRead.createMergeReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<DeletionFile> deletionFiles, boolean keepDelete)
RecordReader<KeyValue>	MergeFileSplitRead.createNoMergeReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<DeletionFile> deletionFiles, boolean onlyFilterKey)
RecordReader<InternalRow>	RawFileSplitRead.createReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<IOExceptionSupplier<DeletionVector>> dvFactories)
RecordReader<InternalRow>	RawFileSplitRead.createReader(DataSplit split)
RecordReader<KeyValue>	MergeFileSplitRead.createReader(DataSplit split)
RecordReader<T>	SplitRead.createReader(DataSplit split) Create a RecordReader from split.

Methods in org.apache.paimon.operation with parameters of type RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	DefaultValueAssigner.assignFieldsDefaultValue(RecordReader<InternalRow> reader) assign default value for column which value is null.

Method parameters in org.apache.paimon.operation with type arguments of type RecordReader

Modifier and Type	Method and Description
static <L,R> SplitRead<R>	SplitRead.convert(SplitRead<L> read, IOFunction<DataSplit,RecordReader<R>> convertedFactory)

Constructors in org.apache.paimon.operation with parameters of type RecordReader

Constructor and Description
ReverseReader(RecordReader<KeyValue> reader)

Uses of RecordReader in org.apache.paimon.reader

Classes in org.apache.paimon.reader that implement RecordReader

Modifier and Type	Class and Description
class	EmptyRecordReader<T> An empty RecordReader.

Methods in org.apache.paimon.reader that return RecordReader

Modifier and Type	Method and Description
default RecordReader<T>	RecordReader.filter(Filter<T> filter) Filters a RecordReader.
RecordReader<T>	ReaderSupplier.get()
default <R> RecordReader<R>	RecordReader.transform(java.util.function.Function<T,R> function) Returns a RecordReader that applies function to each element.

Constructors in org.apache.paimon.reader with parameters of type RecordReader

Constructor and Description
RecordReaderIterator(RecordReader<T> reader)

Uses of RecordReader in org.apache.paimon.table.source

Methods in org.apache.paimon.table.source that return RecordReader

Modifier and Type	Method and Description
default RecordReader<InternalRow>	TableRead.createReader(List<Split> splits)
RecordReader<InternalRow>	TableRead.createReader(Split split)
RecordReader<InternalRow>	AbstractDataTableRead.createReader(Split split)
default RecordReader<InternalRow>	TableRead.createReader(TableScan.Plan plan)
RecordReader<InternalRow>	KeyValueTableRead.reader(Split split)
abstract RecordReader<InternalRow>	AbstractDataTableRead.reader(Split split)
static RecordReader<InternalRow>	KeyValueTableRead.unwrap(RecordReader<KeyValue> reader)

Methods in org.apache.paimon.table.source with parameters of type RecordReader

Modifier and Type	Method and Description
static RecordReader<InternalRow>	KeyValueTableRead.unwrap(RecordReader<KeyValue> reader)

Uses of RecordReader in org.apache.paimon.table.source.splitread

Methods in org.apache.paimon.table.source.splitread that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	IncrementalDiffSplitRead.createReader(DataSplit split)

Uses of RecordReader in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return RecordReader

Modifier and Type	Method and Description
RecordReader<InternalRow>	TableLineageTable.TableLineageRead.createReader(Split split)

Uses of RecordReader in org.apache.paimon.utils

Classes in org.apache.paimon.utils that implement RecordReader

Modifier and Type	Class and Description
class	AsyncRecordReader<T> A RecordReader to use ASYNC_EXECUTOR to read records async.
class	IteratorRecordReader<T> Wrap a Iterator as an RecordReader.

Methods in org.apache.paimon.utils that return RecordReader

Modifier and Type	Method and Description
static RecordReader<InternalRow>	FileUtils.createFormatReader(FileIO fileIO, FormatReaderFactory format, Path file, Long fileSize)

Constructor parameters in org.apache.paimon.utils with type arguments of type RecordReader

Constructor and Description
AsyncRecordReader(IOExceptionSupplier<RecordReader<T>> supplier)
ParallelExecution(Serializer<T> serializer, int pageSize, int parallelism, List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers)