Uses of Interface
org.apache.paimon.data.InternalRow

Packages that use InternalRow

Package	Description
org.apache.paimon
org.apache.paimon.append
org.apache.paimon.arrow
org.apache.paimon.arrow.converter
org.apache.paimon.arrow.reader
org.apache.paimon.arrow.vector
org.apache.paimon.casting
org.apache.paimon.codegen
org.apache.paimon.crosspartition
org.apache.paimon.data
org.apache.paimon.data.columnar
org.apache.paimon.data.safe
org.apache.paimon.data.serializer
org.apache.paimon.deletionvectors
org.apache.paimon.disk
org.apache.paimon.flink
org.apache.paimon.flink.lookup
org.apache.paimon.flink.query
org.apache.paimon.flink.service
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.index
org.apache.paimon.flink.sorter
org.apache.paimon.flink.utils
org.apache.paimon.format
org.apache.paimon.format.avro
org.apache.paimon.format.orc
org.apache.paimon.format.orc.writer
org.apache.paimon.format.parquet
org.apache.paimon.format.parquet.writer
org.apache.paimon.hive
org.apache.paimon.hive.objectinspector
org.apache.paimon.iceberg.manifest
org.apache.paimon.index
org.apache.paimon.io
org.apache.paimon.manifest
org.apache.paimon.memory
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.predicate
org.apache.paimon.sort
org.apache.paimon.sort.hilbert
org.apache.paimon.sort.zorder
org.apache.paimon.spark
org.apache.paimon.stats
org.apache.paimon.table.query
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.splitread
org.apache.paimon.table.system
org.apache.paimon.utils

Uses of InternalRow in org.apache.paimon

Classes in org.apache.paimon that implement InternalRow

Modifier and Type	Class and Description
class	PartitionSettedRow An implementation of InternalRow which provides a row the fixed partition value.

Fields in org.apache.paimon declared as InternalRow

Modifier and Type	Field and Description
protected InternalRow	PartitionSettedRow.row

Methods in org.apache.paimon that return InternalRow

Modifier and Type	Method and Description
InternalRow	PartitionSettedRow.getRow(int pos, int numFields)
InternalRow	KeyValue.key()
InternalRow	KeyValueSerializer.toRow(InternalRow key, long sequenceNumber, RowKind valueKind, InternalRow value)
InternalRow	KeyValueSerializer.toRow(KeyValue record)
InternalRow	KeyValue.value()

Methods in org.apache.paimon that return types with arguments of type InternalRow

Modifier and Type	Method and Description
Comparator<InternalRow>	KeyValueFileStore.newKeyComparator()
Comparator<InternalRow>	AppendOnlyFileStore.newKeyComparator()

Methods in org.apache.paimon with parameters of type InternalRow

Modifier and Type	Method and Description
KeyValue	KeyValueSerializer.fromRow(InternalRow row)
KeyValue	KeyValue.replace(InternalRow key, long sequenceNumber, RowKind valueKind, InternalRow value)
KeyValue	KeyValue.replace(InternalRow key, RowKind valueKind, InternalRow value)
KeyValue	KeyValue.replaceKey(InternalRow key)
PartitionSettedRow	PartitionSettedRow.replaceRow(InternalRow row) Replaces the underlying InternalRow backing this PartitionSettedRow.
KeyValue	KeyValue.replaceValue(InternalRow value)
static String	KeyValue.rowDataToString(InternalRow row, RowType type)
InternalRow	KeyValueSerializer.toRow(InternalRow key, long sequenceNumber, RowKind valueKind, InternalRow value)

Uses of InternalRow in org.apache.paimon.append

Methods in org.apache.paimon.append with parameters of type InternalRow

Modifier and Type	Method and Description
void	AppendOnlyWriter.write(InternalRow rowData)

Constructor parameters in org.apache.paimon.append with type arguments of type InternalRow

Constructor and Description

AppendOnlyWriter(FileIO fileIO, IOManager ioManager, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, long maxSequenceNumber, CompactManager compactManager, IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead, boolean forceCompact, DataFilePathFactory pathFactory, CommitIncrement increment, boolean useWriteBuffer, boolean spillable, String fileCompression, CompressOptions spillCompression, SimpleColStatsCollector.Factory[] statsCollectors, MemorySize maxDiskSize, FileIndexOptions fileIndexOptions, boolean asyncFileWrite)

Uses of InternalRow in org.apache.paimon.arrow

Methods in org.apache.paimon.arrow that return types with arguments of type InternalRow

Modifier and Type	Method and Description
Iterator<InternalRow>	ArrowBundleRecords.iterator()

Uses of InternalRow in org.apache.paimon.arrow.converter

Fields in org.apache.paimon.arrow.converter with type parameters of type InternalRow

Modifier and Type	Field and Description
protected RecordReader.RecordIterator<InternalRow>	ArrowBatchConverter.iterator

Method parameters in org.apache.paimon.arrow.converter with type arguments of type InternalRow

Modifier and Type	Method and Description
void	ArrowPerRowBatchConverter.reset(RecordReader.RecordIterator<InternalRow> iterator)

Uses of InternalRow in org.apache.paimon.arrow.reader

Methods in org.apache.paimon.arrow.reader that return types with arguments of type InternalRow

Modifier and Type	Method and Description
Iterable<InternalRow>	ArrowBatchReader.readBatch(org.apache.arrow.vector.VectorSchemaRoot vsr)

Uses of InternalRow in org.apache.paimon.arrow.vector

Methods in org.apache.paimon.arrow.vector with parameters of type InternalRow

Modifier and Type	Method and Description
boolean	ArrowFormatWriter.write(InternalRow currentRow)
boolean	ArrowFormatCWriter.write(InternalRow currentRow)

Uses of InternalRow in org.apache.paimon.casting

Classes in org.apache.paimon.casting that implement InternalRow

Modifier and Type	Class and Description
class	CastedRow An implementation of InternalRow which provides a casted view of the underlying InternalRow.
class	DefaultValueRow An implementation of InternalRow which provides a default value for the underlying InternalRow.

Methods in org.apache.paimon.casting that return InternalRow

Modifier and Type	Method and Description
InternalRow	DefaultValueRow.defaultValueRow()
InternalRow	CastedRow.getRow(int pos, int numFields)
InternalRow	DefaultValueRow.getRow(int pos, int numFields)

Methods in org.apache.paimon.casting with parameters of type InternalRow

Modifier and Type	Method and Description
static DefaultValueRow	DefaultValueRow.from(InternalRow defaultValueRow)
<V> V	CastFieldGetter.getFieldOrNull(InternalRow row)
CastedRow	CastedRow.replaceRow(InternalRow row) Replaces the underlying InternalRow backing this CastedRow.
DefaultValueRow	DefaultValueRow.replaceRow(InternalRow row)

Uses of InternalRow in org.apache.paimon.codegen

Methods in org.apache.paimon.codegen with parameters of type InternalRow

Modifier and Type	Method and Description
BinaryRow	Projection.apply(InternalRow row)
int	RecordComparator.compare(InternalRow o1, InternalRow o2)
boolean	RecordEqualiser.equals(InternalRow row1, InternalRow row2) Returns true if the rows are equal to each other and false otherwise.
void	NormalizedKeyComputer.putKey(InternalRow record, MemorySegment target, int offset) Writes a normalized key for the given record into the target MemorySegment.

Uses of InternalRow in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition that return types with arguments of type InternalRow

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

Methods in org.apache.paimon.crosspartition with parameters of type InternalRow

Modifier and Type	Method and Description
void	GlobalIndexAssigner.bootstrapKey(InternalRow value)
BinaryRow	KeyPartPartitionKeyExtractor.partition(InternalRow record)
boolean	SkipNewExistingProcessor.processExists(InternalRow newRow, BinaryRow previousPart, int previousBucket)
boolean	ExistingProcessor.processExists(InternalRow newRow, BinaryRow previousPart, int previousBucket)
boolean	UseOldExistingProcessor.processExists(InternalRow newRow, BinaryRow previousPart, int previousBucket)
boolean	DeleteExistingProcessor.processExists(InternalRow newRow, BinaryRow previousPart, int previousBucket)
void	GlobalIndexAssigner.processInput(InternalRow value)
BinaryRow	KeyPartPartitionKeyExtractor.trimmedPrimaryKey(InternalRow record)

Method parameters in org.apache.paimon.crosspartition with type arguments of type InternalRow

Modifier and Type	Method and Description
void	IndexBootstrap.bootstrap(int numAssigners, int assignId, java.util.function.Consumer<InternalRow> collector)
static void	ExistingProcessor.bulkLoadCollectFirst(java.util.function.BiConsumer<InternalRow,Integer> collector, RowIterator iterator, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
static void	ExistingProcessor.bulkLoadCollectFirst(java.util.function.BiConsumer<InternalRow,Integer> collector, RowIterator iterator, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
static void	ExistingProcessor.bulkLoadCollectFirst(java.util.function.BiConsumer<InternalRow,Integer> collector, RowIterator iterator, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	SkipNewExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	SkipNewExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	ExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	ExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	UseOldExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	UseOldExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	DeleteExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
void	DeleteExistingProcessor.bulkLoadNewRecords(java.util.function.Function<ExistingProcessor.SortOrder,RowIterator> iteratorFunction, java.util.function.Function<InternalRow,BinaryRow> extractPrimary, java.util.function.Function<InternalRow,BinaryRow> extractPartition, java.util.function.Function<BinaryRow,Integer> assignBucket)
static ExistingProcessor	ExistingProcessor.create(CoreOptions.MergeEngine mergeEngine, ProjectToRowFunction setPartition, BucketAssigner bucketAssigner, java.util.function.BiConsumer<InternalRow,Integer> collector)
void	GlobalIndexAssigner.open(long offHeapMemory, IOManager ioManager, int numAssigners, int assignId, java.util.function.BiConsumer<InternalRow,Integer> collector)

Constructor parameters in org.apache.paimon.crosspartition with type arguments of type InternalRow

Constructor and Description
DeleteExistingProcessor(ProjectToRowFunction setPartition, BucketAssigner bucketAssigner, java.util.function.BiConsumer<InternalRow,Integer> collector)
SkipNewExistingProcessor(java.util.function.BiConsumer<InternalRow,Integer> collector)
UseOldExistingProcessor(ProjectToRowFunction setPartition, java.util.function.BiConsumer<InternalRow,Integer> collector)

Uses of InternalRow in org.apache.paimon.data

Classes in org.apache.paimon.data that implement InternalRow

Modifier and Type	Class and Description
class	BinaryRow An implementation of InternalRow which is backed by MemorySegment instead of Object.
class	GenericRow An internal data structure representing data of RowType.
class	JoinedRow An implementation of InternalRow which is backed by two concatenated InternalRow.
class	LazyGenericRow A InternalRow which lazy init fields.
class	NestedRow Its memory storage structure is exactly the same with BinaryRow.

Methods in org.apache.paimon.data that return InternalRow

Modifier and Type	Method and Description
InternalRow	LazyGenericRow.getRow(int pos, int numFields)
InternalRow	NestedRow.getRow(int pos, int numFields)
InternalRow	BinaryArray.getRow(int pos, int numFields)
InternalRow	GenericArray.getRow(int pos, int numFields)
InternalRow	GenericRow.getRow(int pos, int numFields)
InternalRow	DataGetters.getRow(int pos, int numFields) Returns the row value at the given position.
InternalRow	JoinedRow.getRow(int pos, int numFields)
InternalRow	BinaryRow.getRow(int pos, int numFields)
InternalRow	JoinedRow.row1()
InternalRow	JoinedRow.row2()

Methods in org.apache.paimon.data with parameters of type InternalRow

Modifier and Type	Method and Description
NestedRow	NestedRow.copy(InternalRow reuse)
Object	InternalRow.FieldGetter.getFieldOrNull(InternalRow row)
static JoinedRow	JoinedRow.join(InternalRow row1, InternalRow row2)
JoinedRow	JoinedRow.replace(InternalRow row1, InternalRow row2) Replaces the InternalRow backing this JoinedRow.
void	BinaryWriter.writeRow(int pos, InternalRow value, InternalRowSerializer serializer)

Constructors in org.apache.paimon.data with parameters of type InternalRow

Constructor and Description
JoinedRow(InternalRow row1, InternalRow row2) Creates a new JoinedRow of kind RowKind.INSERT backed by row1 and row2.
JoinedRow(RowKind rowKind, InternalRow row1, InternalRow row2) Creates a new JoinedRow of kind RowKind.INSERT backed by row1 and row2.

Uses of InternalRow in org.apache.paimon.data.columnar

Classes in org.apache.paimon.data.columnar that implement InternalRow

Modifier and Type	Class and Description
class	ColumnarRow Columnar row to support access to vector column data.

Methods in org.apache.paimon.data.columnar that return InternalRow

Modifier and Type	Method and Description
InternalRow	RowColumnVector.getRow(int i)
InternalRow	ColumnarArray.getRow(int pos, int numFields)
InternalRow	VectorizedColumnBatch.getRow(int rowId, int colId)
InternalRow	ColumnarRow.getRow(int pos, int numFields)
InternalRow	ColumnarRowIterator.next()

Uses of InternalRow in org.apache.paimon.data.safe

Classes in org.apache.paimon.data.safe that implement InternalRow

Modifier and Type	Class and Description
class	SafeBinaryRow A BinaryRow which is safe avoid core dump.

Methods in org.apache.paimon.data.safe that return InternalRow

Modifier and Type	Method and Description
InternalRow	SafeBinaryRow.getRow(int pos, int numFields)
InternalRow	SafeBinaryArray.getRow(int pos, int numFields)

Uses of InternalRow in org.apache.paimon.data.serializer

Classes in org.apache.paimon.data.serializer with type parameters of type InternalRow

Modifier and Type	Class and Description
class	AbstractRowDataSerializer<T extends InternalRow> Row serializer, provided paged serialize paged method.

Methods in org.apache.paimon.data.serializer that return InternalRow

Modifier and Type	Method and Description
InternalRow	RowCompactedSerializer.copy(InternalRow from)
InternalRow	InternalRowSerializer.copy(InternalRow from)
InternalRow	InternalRowSerializer.copyRowData(InternalRow from, InternalRow reuse)
InternalRow	RowCompactedSerializer.deserialize(byte[] bytes)
InternalRow	RowCompactedSerializer.deserialize(DataInputView source)
InternalRow	InternalRowSerializer.deserialize(DataInputView source)
InternalRow	InternalRowSerializer.deserializeFromPages(AbstractPagedInputView source)
InternalRow	InternalRowSerializer.deserializeFromPages(InternalRow reuse, AbstractPagedInputView source)
InternalRow	InternalRowSerializer.mapFromPages(InternalRow reuse, AbstractPagedInputView source)

Methods in org.apache.paimon.data.serializer that return types with arguments of type InternalRow

Modifier and Type	Method and Description
Serializer<InternalRow>	RowCompactedSerializer.duplicate()

Methods in org.apache.paimon.data.serializer with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	RowCompactedSerializer.copy(InternalRow from)
InternalRow	InternalRowSerializer.copy(InternalRow from)
InternalRow	InternalRowSerializer.copyRowData(InternalRow from, InternalRow reuse)
InternalRow	InternalRowSerializer.deserializeFromPages(InternalRow reuse, AbstractPagedInputView source)
InternalRow	InternalRowSerializer.mapFromPages(InternalRow reuse, AbstractPagedInputView source)
void	RowCompactedSerializer.serialize(InternalRow record, DataOutputView target)
void	InternalRowSerializer.serialize(InternalRow row, DataOutputView target)
byte[]	RowCompactedSerializer.serializeToBytes(InternalRow record)
int	InternalRowSerializer.serializeToPages(InternalRow row, AbstractPagedOutputView target)
BinaryRow	InternalRowSerializer.toBinaryRow(InternalRow row) Convert InternalRow into BinaryRow.

Uses of InternalRow in org.apache.paimon.deletionvectors

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

Modifier and Type	Method and Description
InternalRow	ApplyDeletionFileRecordIterator.next()

Methods in org.apache.paimon.deletionvectors that return types with arguments of type InternalRow

Modifier and Type	Method and Description
FileRecordIterator<InternalRow>	ApplyDeletionFileRecordIterator.iterator()
RecordReader.RecordIterator<InternalRow>	ApplyDeletionVectorReader.readBatch()
RecordReader<InternalRow>	ApplyDeletionVectorReader.reader()

Constructor parameters in org.apache.paimon.deletionvectors with type arguments of type InternalRow

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

Uses of InternalRow in org.apache.paimon.disk

Methods in org.apache.paimon.disk with parameters of type InternalRow

Modifier and Type	Method and Description
boolean	InMemoryBuffer.put(InternalRow row)
boolean	RowBuffer.put(InternalRow row)
boolean	ExternalBuffer.put(InternalRow row)

Method parameters in org.apache.paimon.disk with type arguments of type InternalRow

Modifier and Type	Method and Description
static RowBuffer	RowBuffer.getBuffer(IOManager ioManager, MemorySegmentPool memoryPool, AbstractRowDataSerializer<InternalRow> serializer, boolean spillable, MemorySize maxDiskSize, CompressOptions compression)

Uses of InternalRow in org.apache.paimon.flink

Classes in org.apache.paimon.flink that implement InternalRow

Modifier and Type	Class and Description
class	FlinkRowWrapper Convert from Flink row data.

Methods in org.apache.paimon.flink that return InternalRow

Modifier and Type	Method and Description
InternalRow	FlinkRowWrapper.getRow(int pos, int numFields)

Methods in org.apache.paimon.flink with parameters of type InternalRow

Modifier and Type	Method and Description
FlinkRowData	FlinkRowData.replace(InternalRow row)

Constructors in org.apache.paimon.flink with parameters of type InternalRow

Constructor and Description
FlinkRowData(InternalRow row)

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

Fields in org.apache.paimon.flink.lookup with type parameters of type InternalRow

Modifier and Type	Field and Description
protected RocksDBValueState<InternalRow,InternalRow>	PrimaryKeyLookupTable.tableState
protected RocksDBValueState<InternalRow,InternalRow>	PrimaryKeyLookupTable.tableState

Methods in org.apache.paimon.flink.lookup that return types with arguments of type InternalRow

Modifier and Type	Method and Description
List<InternalRow>	LookupTable.get(InternalRow key)
List<InternalRow>	FullCacheLookupTable.get(InternalRow key)
List<InternalRow>	PrimaryKeyPartialLookupTable.get(InternalRow key)
abstract List<InternalRow>	FullCacheLookupTable.innerGet(InternalRow key)
List<InternalRow>	SecondaryIndexLookupTable.innerGet(InternalRow key)
List<InternalRow>	NoPrimaryKeyLookupTable.innerGet(InternalRow key)
List<InternalRow>	PrimaryKeyLookupTable.innerGet(InternalRow key)
RecordReader<InternalRow>	LookupStreamingReader.nextBatch(boolean useParallelism)

Methods in org.apache.paimon.flink.lookup with parameters of type InternalRow

Modifier and Type	Method and Description
List<InternalRow>	LookupTable.get(InternalRow key)
List<InternalRow>	FullCacheLookupTable.get(InternalRow key)
List<InternalRow>	PrimaryKeyPartialLookupTable.get(InternalRow key)
abstract List<InternalRow>	FullCacheLookupTable.innerGet(InternalRow key)
List<InternalRow>	SecondaryIndexLookupTable.innerGet(InternalRow key)
List<InternalRow>	NoPrimaryKeyLookupTable.innerGet(InternalRow key)
List<InternalRow>	PrimaryKeyLookupTable.innerGet(InternalRow key)
protected abstract void	FullCacheLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	SecondaryIndexLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	NoPrimaryKeyLookupTable.refreshRow(InternalRow row, Predicate predicate)
protected void	PrimaryKeyLookupTable.refreshRow(InternalRow row, Predicate predicate)
void	FixedBucketFromPkExtractor.setRecord(InternalRow record)
abstract byte[]	FullCacheLookupTable.toKeyBytes(InternalRow row)
byte[]	NoPrimaryKeyLookupTable.toKeyBytes(InternalRow row)
byte[]	PrimaryKeyLookupTable.toKeyBytes(InternalRow row)
abstract byte[]	FullCacheLookupTable.toValueBytes(InternalRow row)
byte[]	NoPrimaryKeyLookupTable.toValueBytes(InternalRow row)
byte[]	PrimaryKeyLookupTable.toValueBytes(InternalRow row)

Method parameters in org.apache.paimon.flink.lookup with type arguments of type InternalRow

Modifier and Type	Method and Description
void	FullCacheLookupTable.refresh(Iterator<InternalRow> input)
void	NoPrimaryKeyLookupTable.refresh(Iterator<InternalRow> incremental)

Uses of InternalRow in org.apache.paimon.flink.query

Methods in org.apache.paimon.flink.query that return InternalRow

Modifier and Type	Method and Description
InternalRow	RemoteTableQuery.lookup(BinaryRow partition, int bucket, InternalRow key)

Methods in org.apache.paimon.flink.query with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	RemoteTableQuery.lookup(BinaryRow partition, int bucket, InternalRow key)

Uses of InternalRow in org.apache.paimon.flink.service

Methods in org.apache.paimon.flink.service that return types with arguments of type InternalRow

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<InternalRow>	QueryFileMonitor.build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
static ChannelComputer<InternalRow>	QueryFileMonitor.createChannelComputer()

Methods in org.apache.paimon.flink.service with parameters of type InternalRow

Modifier and Type	Method and Description
void	QueryAddressRegister.invoke(InternalRow row, org.apache.flink.streaming.api.functions.sink.SinkFunction.Context context)

Method parameters in org.apache.paimon.flink.service with type arguments of type InternalRow

Modifier and Type	Method and Description
void	QueryExecutorOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> streamRecord)
void	QueryFileMonitor.run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<InternalRow> ctx)

Uses of InternalRow in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return types with arguments of type InternalRow

Modifier and Type	Method and Description
protected ChannelComputer<InternalRow>	RowDynamicBucketSink.assignerChannelComputer(Integer numAssigners)
protected ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>	RowDynamicBucketSink.channelComputer2()
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	FixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	RowDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	RowUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>>	RowDynamicBucketSink.extractorFunction()
protected org.apache.flink.streaming.api.datastream.DataStream<InternalRow>	FlinkSinkBuilder.mapToInternalRow(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input, RowType rowType)

Methods in org.apache.paimon.flink.sink with parameters of type InternalRow

Modifier and Type	Method and Description
int	RowDataChannelComputer.channel(InternalRow record)
int	RowAssignerChannelComputer.channel(InternalRow record)
SinkRecord	StoreSinkWrite.write(InternalRow rowData)
SinkRecord	GlobalFullCompactionSinkWrite.write(InternalRow rowData)
SinkRecord	StoreSinkWriteImpl.write(InternalRow rowData)
SinkRecord	StoreSinkWrite.write(InternalRow rowData, int bucket)
SinkRecord	GlobalFullCompactionSinkWrite.write(InternalRow rowData, int bucket)
SinkRecord	StoreSinkWriteImpl.write(InternalRow rowData, int bucket)

Method parameters in org.apache.paimon.flink.sink with type arguments of type InternalRow

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	DynamicBucketCompactSink.build(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input, Integer parallelism)
protected org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkSinkBuilder.buildDynamicBucketSink(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input, boolean globalIndex)
protected org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkSinkBuilder.buildForFixedBucket(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input)
int	RowWithBucketChannelComputer.channel(org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer> record)
void	LocalMergeOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> record)
void	RowDataStoreWriteOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> element)
void	DynamicBucketRowWriteOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>> element)

Uses of InternalRow in org.apache.paimon.flink.sink.index

Methods in org.apache.paimon.flink.sink.index that return types with arguments of type InternalRow

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	GlobalDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

Method parameters in org.apache.paimon.flink.sink.index with type arguments of type InternalRow

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	GlobalDynamicBucketSink.build(org.apache.flink.streaming.api.datastream.DataStream<InternalRow> input, Integer parallelism)
int	KeyPartRowChannelComputer.channel(org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow> record)
void	GlobalIndexAssignerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.api.java.tuple.Tuple2<KeyPartOrRow,InternalRow>> streamRecord)

Constructor parameters in org.apache.paimon.flink.sink.index with type arguments of type InternalRow

Constructor and Description
IndexBootstrapOperator(IndexBootstrap bootstrap, SerializableFunction<InternalRow,T> converter)

Uses of InternalRow in org.apache.paimon.flink.sorter

Method parameters in org.apache.paimon.flink.sorter with type arguments of type InternalRow

Modifier and Type	Method and Description
void	SortOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> element)

Uses of InternalRow in org.apache.paimon.flink.utils

Methods in org.apache.paimon.flink.utils that return InternalRow

Modifier and Type	Method and Description
InternalRow	InternalRowTypeSerializer.copy(InternalRow from)
InternalRow	InternalRowTypeSerializer.copy(InternalRow from, InternalRow reuse)
InternalRow	InternalRowTypeSerializer.createInstance()
InternalRow	InternalRowTypeSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)
InternalRow	InternalRowTypeSerializer.deserialize(InternalRow reuse, org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.paimon.flink.utils that return types with arguments of type InternalRow

Modifier and Type	Method and Description
org.apache.flink.api.common.typeutils.TypeSerializer<InternalRow>	InternalRowTypeSerializer.duplicate()
static InternalTypeInfo<InternalRow>	InternalTypeInfo.fromRowType(RowType rowType)

Methods in org.apache.paimon.flink.utils with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	InternalRowTypeSerializer.copy(InternalRow from)
InternalRow	InternalRowTypeSerializer.copy(InternalRow from, InternalRow reuse)
InternalRow	InternalRowTypeSerializer.deserialize(InternalRow reuse, org.apache.flink.core.memory.DataInputView source)
void	InternalRowTypeSerializer.serialize(InternalRow record, org.apache.flink.core.memory.DataOutputView target)

Uses of InternalRow in org.apache.paimon.format

Methods in org.apache.paimon.format that return types with arguments of type InternalRow

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

Methods in org.apache.paimon.format with parameters of type InternalRow

Modifier and Type	Method and Description
void	FormatWriter.addElement(InternalRow element) Adds an element to the encoder.
void	SimpleStatsCollector.collect(InternalRow row) Update the statistics with a new row data.

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

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

Modifier and Type	Method and Description
InternalRow	FieldReaderFactory.RowReader.read(org.apache.avro.io.Decoder decoder, Object reuse)
InternalRow	AvroRowDatumReader.read(InternalRow reuse, org.apache.avro.io.Decoder in)

Methods in org.apache.paimon.format.avro that return types with arguments of type InternalRow

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

Methods in org.apache.paimon.format.avro with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	AvroRowDatumReader.read(InternalRow reuse, org.apache.avro.io.Decoder in)
void	AvroRowDatumWriter.write(InternalRow datum, org.apache.avro.io.Encoder out)
void	FieldWriterFactory.RowWriter.writeRow(InternalRow row, org.apache.avro.io.Encoder encoder)

Uses of InternalRow in org.apache.paimon.format.orc

Constructor parameters in org.apache.paimon.format.orc with type arguments of type InternalRow

Constructor and Description
OrcWriterFactory(Vectorizer<InternalRow> vectorizer, Properties writerProperties, org.apache.hadoop.conf.Configuration configuration, int writeBatchSize) Creates a new OrcBulkWriterFactory using the provided Vectorizer, Hadoop Configuration, ORC writer properties.

Uses of InternalRow in org.apache.paimon.format.orc.writer

Methods in org.apache.paimon.format.orc.writer with parameters of type InternalRow

Modifier and Type	Method and Description
void	OrcBulkWriter.addElement(InternalRow element)
void	RowDataVectorizer.vectorize(InternalRow row, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)

Constructor parameters in org.apache.paimon.format.orc.writer with type arguments of type InternalRow

Constructor and Description
OrcBulkWriter(Vectorizer<InternalRow> vectorizer, org.apache.orc.Writer writer, PositionOutputStream underlyingStream, int batchSize)

Uses of InternalRow in org.apache.paimon.format.parquet

Constructor parameters in org.apache.paimon.format.parquet with type arguments of type InternalRow

Constructor and Description
ParquetWriterFactory(ParquetBuilder<InternalRow> writerBuilder) Creates a new ParquetWriterFactory using the given builder to assemble the ParquetWriter.

Uses of InternalRow in org.apache.paimon.format.parquet.writer

Methods in org.apache.paimon.format.parquet.writer that return types with arguments of type InternalRow

Modifier and Type	Method and Description
ParquetWriter<InternalRow>	RowDataParquetBuilder.createWriter(org.apache.parquet.io.OutputFile out, String compression)
protected org.apache.parquet.hadoop.api.WriteSupport<InternalRow>	ParquetRowDataBuilder.getWriteSupport(org.apache.hadoop.conf.Configuration conf)

Methods in org.apache.paimon.format.parquet.writer with parameters of type InternalRow

Modifier and Type	Method and Description
void	ParquetBulkWriter.addElement(InternalRow datum)
void	ParquetRowDataWriter.write(InternalRow record) It writes a record to Parquet.

Constructor parameters in org.apache.paimon.format.parquet.writer with type arguments of type InternalRow

Constructor and Description
ParquetBulkWriter(ParquetWriter<InternalRow> parquetWriter) Creates a new ParquetBulkWriter wrapping the given ParquetWriter.

Uses of InternalRow in org.apache.paimon.hive

Methods in org.apache.paimon.hive that return InternalRow

Modifier and Type	Method and Description
InternalRow	RowDataContainer.get()

Methods in org.apache.paimon.hive with parameters of type InternalRow

Modifier and Type	Method and Description
void	RowDataContainer.set(InternalRow rowData)

Uses of InternalRow in org.apache.paimon.hive.objectinspector

Methods in org.apache.paimon.hive.objectinspector that return InternalRow

Modifier and Type	Method and Description
InternalRow	HivePaimonArray.getRow(int i, int i1)

Uses of InternalRow in org.apache.paimon.iceberg.manifest

Methods in org.apache.paimon.iceberg.manifest that return InternalRow

Modifier and Type	Method and Description
InternalRow	IcebergDataFileMetaSerializer.toRow(IcebergDataFileMeta file)
InternalRow	IcebergManifestEntrySerializer.toRow(IcebergManifestEntry entry)
InternalRow	IcebergManifestFileMetaSerializer.toRow(IcebergManifestFileMeta file)
InternalRow	IcebergPartitionSummarySerializer.toRow(IcebergPartitionSummary record)

Methods in org.apache.paimon.iceberg.manifest with parameters of type InternalRow

Modifier and Type	Method and Description
IcebergManifestFileMeta	IcebergManifestFileMetaSerializer.fromRow(InternalRow row)
IcebergDataFileMeta	IcebergDataFileMetaSerializer.fromRow(InternalRow row)
IcebergPartitionSummary	IcebergPartitionSummarySerializer.fromRow(InternalRow row)
IcebergManifestEntry	IcebergManifestEntrySerializer.fromRow(InternalRow row)

Uses of InternalRow in org.apache.paimon.index

Methods in org.apache.paimon.index that return InternalRow

Modifier and Type	Method and Description
InternalRow	IndexFileMetaSerializer.toRow(IndexFileMeta record)

Methods in org.apache.paimon.index with parameters of type InternalRow

Modifier and Type	Method and Description
IndexFileMeta	IndexFileMetaSerializer.fromRow(InternalRow row)

Uses of InternalRow in org.apache.paimon.io

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

Modifier and Type	Method and Description
InternalRow	DataFileMetaSerializer.toRow(DataFileMeta meta)
InternalRow	IdentifierSerializer.toRow(Identifier record)
protected InternalRow	SingleFileWriter.writeImpl(T record)

Methods in org.apache.paimon.io that return types with arguments of type InternalRow

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)
RecordReader.RecordIterator<InternalRow>	FileRecordReader.readBatch()

Methods in org.apache.paimon.io with parameters of type InternalRow

Modifier and Type	Method and Description
DataFileMeta	DataFileMetaSerializer.fromRow(InternalRow row)
Identifier	IdentifierSerializer.fromRow(InternalRow rowData)
void	DataFileIndexWriter.write(InternalRow row)
void	RowDataFileWriter.write(InternalRow row)

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

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)
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)
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)

Constructor parameters in org.apache.paimon.io with type arguments of type InternalRow

Constructor and Description
KeyValueDataFileRecordReader(RecordReader<InternalRow> reader, RowType keyType, RowType valueType, int level)
KeyValueDataFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<KeyValue,InternalRow> converter, RowType keyType, RowType valueType, SimpleStatsExtractor simpleStatsExtractor, long schemaId, int level, String compression, CoreOptions options, FileSource fileSource)
SingleFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<T,InternalRow> converter, String compression, boolean asyncWrite)
StatsCollectingSingleFileWriter(FileIO fileIO, FormatWriterFactory factory, Path path, java.util.function.Function<T,InternalRow> converter, RowType writeSchema, SimpleStatsExtractor simpleStatsExtractor, String compression, SimpleColStatsCollector.Factory[] statsCollectors, boolean asyncWrite)

Uses of InternalRow in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return InternalRow

Modifier and Type	Method and Description
InternalRow	IndexManifestEntrySerializer.convertTo(IndexManifestEntry record)
InternalRow	ManifestEntrySerializer.convertTo(ManifestEntry entry)
InternalRow	ManifestFileMetaSerializer.convertTo(ManifestFileMeta meta)
InternalRow	SimpleFileEntrySerializer.convertTo(SimpleFileEntry meta)

Methods in org.apache.paimon.manifest that return types with arguments of type InternalRow

Modifier and Type	Method and Description
static java.util.function.Function<InternalRow,Integer>	ManifestEntrySerializer.bucketGetter()
static Filter<InternalRow>	FileEntry.deletedFilter()
static java.util.function.Function<InternalRow,String>	ManifestEntrySerializer.fileNameGetter()
static java.util.function.Function<InternalRow,FileKind>	ManifestEntrySerializer.kindGetter()
static java.util.function.Function<InternalRow,BinaryRow>	ManifestEntrySerializer.partitionGetter()
static java.util.function.Function<InternalRow,Integer>	ManifestEntrySerializer.totalBucketGetter()

Methods in org.apache.paimon.manifest with parameters of type InternalRow

Modifier and Type	Method and Description
SimpleFileEntry	SimpleFileEntrySerializer.convertFrom(int version, InternalRow row)
ManifestEntry	ManifestEntrySerializer.convertFrom(int version, InternalRow row)
IndexManifestEntry	IndexManifestEntrySerializer.convertFrom(int version, InternalRow row)
ManifestFileMeta	ManifestFileMetaSerializer.convertFrom(int version, InternalRow row)

Uses of InternalRow in org.apache.paimon.memory

Methods in org.apache.paimon.memory that return InternalRow

Modifier and Type	Method and Description
static InternalRow	MemorySegmentUtils.readRowData(MemorySegment[] segments, int numFields, int baseOffset, long offsetAndSize) Gets an instance of InternalRow from underlying MemorySegment.

Uses of InternalRow in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree with parameters of type InternalRow

Modifier and Type	Method and Description
static <T> T	LookupUtils.lookup(Comparator<InternalRow> keyComparator, InternalRow target, SortedRun level, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
T	LookupLevels.lookup(InternalRow key, int startLevel)
static <T> T	LookupUtils.lookup(Levels levels, InternalRow key, int startLevel, BiFunctionWithIOE<InternalRow,SortedRun,T> lookup, BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
static <T> T	LookupUtils.lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
boolean	WriteBuffer.put(long sequenceNumber, RowKind valueKind, InternalRow key, InternalRow value) Put a record with sequence number and value kind.
boolean	SortBufferWriteBuffer.put(long sequenceNumber, RowKind valueKind, InternalRow key, InternalRow value)
T	LookupLevels.ValueProcessor.readFromDisk(InternalRow key, int level, byte[] valueBytes, String fileName)
KeyValue	LookupLevels.KeyValueProcessor.readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)
Boolean	LookupLevels.ContainsValueProcessor.readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)
LookupLevels.PositionedKeyValue	LookupLevels.PositionedKeyValueProcessor.readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)

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

Modifier and Type	Method and Description
void	WriteBuffer.forEach(Comparator<InternalRow> keyComparator, MergeFunction<KeyValue> mergeFunction, WriteBuffer.KvConsumer rawConsumer, WriteBuffer.KvConsumer mergedConsumer) Performs the given action for each remaining element in this buffer until all elements have been processed or the action throws an exception.
void	SortBufferWriteBuffer.forEach(Comparator<InternalRow> keyComparator, MergeFunction<KeyValue> mergeFunction, WriteBuffer.KvConsumer rawConsumer, WriteBuffer.KvConsumer mergedConsumer)
static SortedRun	SortedRun.fromUnsorted(List<DataFileMeta> unsortedFiles, Comparator<InternalRow> keyComparator)
static <T> T	LookupUtils.lookup(Comparator<InternalRow> keyComparator, InternalRow target, SortedRun level, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	LookupUtils.lookup(Comparator<InternalRow> keyComparator, InternalRow target, SortedRun level, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	LookupUtils.lookup(Levels levels, InternalRow key, int startLevel, BiFunctionWithIOE<InternalRow,SortedRun,T> lookup, BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
static <T> T	LookupUtils.lookup(Levels levels, InternalRow key, int startLevel, BiFunctionWithIOE<InternalRow,SortedRun,T> lookup, BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
static <T> T	LookupUtils.lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	LookupUtils.lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
<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)
void	SortedRun.validate(Comparator<InternalRow> comparator)

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

Constructor and Description
Levels(Comparator<InternalRow> keyComparator, List<DataFileMeta> inputFiles, int numLevels)
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)
MergeTreeWriter(boolean writeBufferSpillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions sortCompression, IOManager ioManager, CompactManager compactManager, long maxSequenceNumber, Comparator<InternalRow> keyComparator, MergeFunction<KeyValue> mergeFunction, KeyValueFileWriterFactory writerFactory, boolean commitForceCompact, CoreOptions.ChangelogProducer changelogProducer, CommitIncrement increment, FieldsComparator userDefinedSeqComparator)

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

Fields in org.apache.paimon.mergetree.compact with type parameters of type InternalRow

Modifier and Type	Field and Description
protected Comparator<InternalRow>	MergeTreeCompactRewriter.keyComparator

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

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 InternalRow

Constructor and Description
ChangelogMergeTreeRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, boolean produceChangelog, boolean forceDropDelete)
FirstRowMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, Filter<InternalRow> contains)
FullChangelogMergeTreeCompactRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, RecordEqualiser valueEqualiser)
IntervalPartition(List<DataFileMeta> inputFiles, Comparator<InternalRow> keyComparator)
LookupChangelogMergeFunctionWrapper(MergeFunctionFactory<KeyValue> mergeFunctionFactory, java.util.function.Function<InternalRow,T> lookup, RecordEqualiser valueEqualiser, LookupStrategy lookupStrategy, DeletionVectorsMaintainer deletionVectorsMaintainer, UserDefinedSeqComparator userDefinedSeqComparator)
LookupMergeTreeCompactRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, LookupLevels<T> lookupLevels, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory<T> wrapperFactory, boolean produceChangelog, DeletionVectorsMaintainer dvMaintainer, CoreOptions options)
MergeTreeCompactManager(ExecutorService executor, Levels levels, CompactStrategy strategy, Comparator<InternalRow> keyComparator, long compactionFileSize, int numSortedRunStopTrigger, CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter, DeletionVectorsMaintainer dvMaintainer, boolean lazyGenDeletionFile)
MergeTreeCompactRewriter(FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter)
MergeTreeCompactTask(Comparator<InternalRow> keyComparator, long minFileSize, CompactRewriter rewriter, CompactUnit unit, boolean dropDelete, int maxLevel, CompactionMetrics.Reporter metricsReporter, java.util.function.Supplier<CompactDeletionFile> compactDfSupplier)
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 InternalRow in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return types with arguments of type InternalRow

Modifier and Type	Method and Description
RecordReader<InternalRow>	DefaultValueAssigner.assignFieldsDefaultValue(RecordReader<InternalRow> reader) assign default value for column which value is null.
RecordReader<InternalRow>	RawFileSplitRead.createReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<IOExceptionSupplier<DeletionVector>> dvFactories)
RecordReader<InternalRow>	RawFileSplitRead.createReader(DataSplit split)
protected RecordWriter<InternalRow>	AppendOnlyFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
SplitRead<InternalRow>	RawFileSplitRead.forceKeepDelete()
Comparator<InternalRow>	MergeFileSplitRead.keyComparator()
SplitRead<InternalRow>	RawFileSplitRead.withIOManager(IOManager ioManager)

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

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

Constructor parameters in org.apache.paimon.operation with type arguments of type InternalRow

Constructor and Description
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, String commitUser, RowType partitionType, String partitionDefaultName, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, IndexManifestFile.Factory indexManifestFileFactory, FileStoreScan scan, int numBucket, MemorySize manifestTargetSize, MemorySize manifestFullCompactionSize, int manifestMergeMinCount, boolean dynamicPartitionOverwrite, Comparator<InternalRow> keyComparator, String branchName, StatsFileHandler statsFileHandler, BucketMode bucketMode, Integer manifestReadParallelism, List<CommitCallback> commitCallbacks, int commitMaxRetries)
KeyValueFileStoreWrite(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, String commitUser, RowType partitionType, RowType keyType, RowType valueType, java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier, java.util.function.Supplier<FieldsComparator> udsComparatorSupplier, java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier, MergeFunctionFactory<KeyValue> mfFactory, FileStorePathFactory pathFactory, Map<String,FileStorePathFactory> format2PathFactory, SnapshotManager snapshotManager, FileStoreScan scan, IndexMaintainer.Factory<KeyValue> indexFactory, DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory, CoreOptions options, KeyValueFieldsExtractor extractor, String tableName)
MergeFileSplitRead(CoreOptions options, TableSchema schema, RowType keyType, RowType valueType, Comparator<InternalRow> keyComparator, MergeFunctionFactory<KeyValue> mfFactory, KeyValueFileReaderFactory.Builder readerFactoryBuilder)

Uses of InternalRow in org.apache.paimon.partition

Methods in org.apache.paimon.partition with parameters of type InternalRow

Modifier and Type	Method and Description
boolean	PartitionPredicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)
boolean	PartitionPredicate.DefaultPartitionPredicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)
boolean	PartitionPredicate.MultiplePartitionPredicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)

Uses of InternalRow in org.apache.paimon.predicate

Methods in org.apache.paimon.predicate with parameters of type InternalRow

Modifier and Type	Method and Description
boolean	Predicate.test(InternalRow row) Test based on the specific input row.
boolean	LeafPredicate.test(InternalRow row)
boolean	CompoundPredicate.test(InternalRow row)
boolean	Or.test(InternalRow row, List<Predicate> children)
boolean	And.test(InternalRow row, List<Predicate> children)
abstract boolean	CompoundPredicate.Function.test(InternalRow row, List<Predicate> children)
boolean	Predicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts) Test based on the statistical information to determine whether a hit is possible.
boolean	LeafPredicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)
boolean	CompoundPredicate.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts)
boolean	Or.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)
boolean	And.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)
abstract boolean	CompoundPredicate.Function.test(long rowCount, InternalRow minValues, InternalRow maxValues, InternalArray nullCounts, List<Predicate> children)

Uses of InternalRow in org.apache.paimon.sort

Methods in org.apache.paimon.sort with parameters of type InternalRow

Modifier and Type	Method and Description
boolean	BinaryExternalSortBuffer.write(InternalRow record)
boolean	BinaryInMemorySortBuffer.write(InternalRow record) Writes a given record to this sort buffer.
boolean	SortBuffer.write(InternalRow record)
protected void	BinaryIndexedSortable.writeIndexAndNormalizedKey(InternalRow record, long currOffset) Write of index and normalizedKey.

Method parameters in org.apache.paimon.sort with type arguments of type InternalRow

Modifier and Type	Method and Description
static BinaryInMemorySortBuffer	BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, AbstractRowDataSerializer<InternalRow> serializer, RecordComparator comparator, MemorySegmentPool memoryPool) Create a memory sorter in `insert` way.

Uses of InternalRow in org.apache.paimon.sort.hilbert

Methods in org.apache.paimon.sort.hilbert with parameters of type InternalRow

Modifier and Type	Method and Description
Long	HilbertIndexer.RowProcessor.hilbertValue(InternalRow o)
byte[]	HilbertIndexer.index(InternalRow row)

Uses of InternalRow in org.apache.paimon.sort.zorder

Methods in org.apache.paimon.sort.zorder with parameters of type InternalRow

Modifier and Type	Method and Description
byte[]	ZIndexer.index(InternalRow row)
byte[]	ZIndexer.RowProcessor.zvalue(InternalRow o)

Uses of InternalRow in org.apache.paimon.spark

Classes in org.apache.paimon.spark that implement InternalRow

Modifier and Type	Class and Description
class	SparkRow A InternalRow wraps spark Row.

Methods in org.apache.paimon.spark that return InternalRow

Modifier and Type	Method and Description
InternalRow	SparkRow.getRow(int i, int i1)

Methods in org.apache.paimon.spark with parameters of type InternalRow

Modifier and Type	Method and Description
static org.apache.spark.sql.catalyst.InternalRow	SparkInternalRow.fromPaimon(InternalRow row, RowType rowType)
SparkInternalRow	SparkInternalRow.replace(InternalRow row)

Uses of InternalRow in org.apache.paimon.stats

Methods in org.apache.paimon.stats that return InternalRow

Modifier and Type	Method and Description
InternalRow	SimpleStatsConverter.evolution(BinaryRow values)
InternalRow	SimpleStats.toRow()

Methods in org.apache.paimon.stats with parameters of type InternalRow

Modifier and Type	Method and Description
static SimpleStats	SimpleStats.fromRow(InternalRow row)

Uses of InternalRow in org.apache.paimon.table.query

Methods in org.apache.paimon.table.query that return InternalRow

Modifier and Type	Method and Description
InternalRow	TableQuery.lookup(BinaryRow partition, int bucket, InternalRow key)
InternalRow	LocalTableQuery.lookup(BinaryRow partition, int bucket, InternalRow key) TODO remove synchronized and supports multiple thread to lookup.

Methods in org.apache.paimon.table.query with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	TableQuery.lookup(BinaryRow partition, int bucket, InternalRow key)
InternalRow	LocalTableQuery.lookup(BinaryRow partition, int bucket, InternalRow key) TODO remove synchronized and supports multiple thread to lookup.

Uses of InternalRow in org.apache.paimon.table.sink

Fields in org.apache.paimon.table.sink declared as InternalRow

Modifier and Type	Field and Description
protected InternalRow	RowKeyExtractor.record

Methods in org.apache.paimon.table.sink that return InternalRow

Modifier and Type	Method and Description
InternalRow	SinkRecord.row()

Methods in org.apache.paimon.table.sink with parameters of type InternalRow

Modifier and Type	Method and Description
RowKind	RowKindGenerator.generate(InternalRow row)
int	TableWrite.getBucket(InternalRow row) Calculate which bucket row belongs to.
int	TableWriteImpl.getBucket(InternalRow row)
BinaryRow	TableWrite.getPartition(InternalRow row) Calculate which partition row belongs to.
BinaryRow	TableWriteImpl.getPartition(InternalRow row)
static RowKind	RowKindGenerator.getRowKind(RowKindGenerator rowKindGenerator, InternalRow row)
BinaryRow	RowPartitionKeyExtractor.partition(InternalRow record)
int	FixedBucketWriteSelector.select(InternalRow row, int numWriters)
int	WriteSelector.select(InternalRow row, int numWriters) Returns the logical writer index, to which the given record should be written.
void	RowKeyExtractor.setRecord(InternalRow record)
void	FixedBucketRowKeyExtractor.setRecord(InternalRow record)
BinaryRow	RowPartitionKeyExtractor.trimmedPrimaryKey(InternalRow record)
void	TableWrite.write(InternalRow row) Write a row to the writer.
void	TableWriteImpl.write(InternalRow row)
void	TableWrite.write(InternalRow row, int bucket) Write a row with bucket.
void	TableWriteImpl.write(InternalRow row, int bucket)
SinkRecord	TableWriteImpl.writeAndReturn(InternalRow row)
SinkRecord	TableWriteImpl.writeAndReturn(InternalRow row, int bucket)

Constructors in org.apache.paimon.table.sink with parameters of type InternalRow

Constructor and Description
SinkRecord(BinaryRow partition, int bucket, BinaryRow primaryKey, InternalRow row)

Constructor parameters in org.apache.paimon.table.sink with type arguments of type InternalRow

Constructor and Description
TableWriteImpl(RowType rowType, FileStoreWrite<T> write, KeyAndBucketExtractor<InternalRow> keyAndBucketExtractor, TableWriteImpl.RecordExtractor<T> recordExtractor, RowKindGenerator rowKindGenerator, boolean ignoreDelete)

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

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

Modifier and Type	Method and Description
InternalRow	ValueContentRowDataRecordIterator.next()

Methods in org.apache.paimon.table.source that return types with arguments of type InternalRow

Modifier and Type	Method and Description
default RecordReader<InternalRow>	TableRead.createReader(List<Split> splits)
RecordReader<InternalRow>	AbstractDataTableRead.createReader(Split split)
RecordReader<InternalRow>	TableRead.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)

Constructor parameters in org.apache.paimon.table.source with type arguments of type InternalRow

Constructor and Description
MergeTreeSplitGenerator(Comparator<InternalRow> keyComparator, long targetSplitSize, long openFileCost, boolean deletionVectorsEnabled, CoreOptions.MergeEngine mergeEngine)

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

Methods in org.apache.paimon.table.source.splitread that return types with arguments of type InternalRow

Modifier and Type	Method and Description
RecordReader<InternalRow>	IncrementalDiffSplitRead.createReader(DataSplit split)
SplitRead<InternalRow>	IncrementalDiffSplitRead.forceKeepDelete()
SplitRead<InternalRow>	IncrementalDiffReadProvider.getOrCreate()
SplitRead<InternalRow>	MergeFileSplitReadProvider.getOrCreate()
SplitRead<InternalRow>	SplitReadProvider.getOrCreate()
SplitRead<InternalRow>	RawFileSplitReadProvider.getOrCreate()
SplitRead<InternalRow>	IncrementalChangelogReadProvider.getOrCreate()
SplitRead<InternalRow>	IncrementalDiffSplitRead.withFilter(Predicate predicate)
SplitRead<InternalRow>	IncrementalDiffSplitRead.withIOManager(IOManager ioManager)
SplitRead<InternalRow>	IncrementalDiffSplitRead.withProjection(int[][] projectedFields)

Constructor parameters in org.apache.paimon.table.source.splitread with type arguments of type InternalRow

Constructor and Description
IncrementalChangelogReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
IncrementalDiffReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
MergeFileSplitReadProvider(java.util.function.Supplier<MergeFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)
RawFileSplitReadProvider(java.util.function.Supplier<RawFileSplitRead> supplier, java.util.function.Consumer<SplitRead<InternalRow>> valuesAssigner)

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

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

Modifier and Type	Method and Description
static InternalRow	FileMonitorTable.toRow(FileMonitorTable.FileChange change)

Methods in org.apache.paimon.table.system that return types with arguments of type InternalRow

Modifier and Type	Method and Description
RecordReader<InternalRow>	TableLineageTable.TableLineageRead.createReader(Split split)
protected static Iterator<InternalRow>	AllTableOptionsTable.toRow(Map<String,Map<String,Map<String,String>>> option)

Methods in org.apache.paimon.table.system with parameters of type InternalRow

Modifier and Type	Method and Description
static FileMonitorTable.FileChange	FileMonitorTable.toFileChange(InternalRow row)

Uses of InternalRow in org.apache.paimon.utils

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

Modifier and Type	Class and Description
class	KeyProjectedRow A InternalRow to project key fields with RowKind.INSERT.
class	OffsetRow A InternalRow to wrap row with offset.
class	PartialRow A InternalRow to wrap row with partial fields.
class	ProjectedRow An implementation of InternalRow which provides a projected view of the underlying InternalRow.

Fields in org.apache.paimon.utils declared as InternalRow

Modifier and Type	Field and Description
protected InternalRow	ProjectedRow.row

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

Modifier and Type	Method and Description
InternalRow	ProjectToRowFunction.apply(InternalRow input, BinaryRow project)
abstract InternalRow	VersionedObjectSerializer.convertTo(T record)
static InternalRow	InternalRowUtils.copyInternalRow(InternalRow row, RowType rowType)
InternalRow	PartialRow.getRow(int pos, int numFields)
InternalRow	OffsetRow.getRow(int pos, int numFields)
InternalRow	KeyProjectedRow.getRow(int pos, int numFields)
InternalRow	ProjectedRow.getRow(int pos, int numFields)
InternalRow	RowIterator.next()
InternalRow	IteratorResultIterator.next()
InternalRow	IntObjectSerializer.toRow(Integer record)
InternalRow	KeyValueWithLevelNoReusingSerializer.toRow(KeyValue kv)
InternalRow	VersionedObjectSerializer.toRow(T record)
abstract InternalRow	ObjectSerializer.toRow(T record) Convert a T to InternalRow.

Methods in org.apache.paimon.utils that return types with arguments of type InternalRow

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

Methods in org.apache.paimon.utils with parameters of type InternalRow

Modifier and Type	Method and Description
InternalRow	ProjectToRowFunction.apply(InternalRow input, BinaryRow project)
int	UserDefinedSeqComparator.compare(InternalRow o1, InternalRow o2)
Object[]	RowDataToObjectArrayConverter.convert(InternalRow rowData)
abstract T	VersionedObjectSerializer.convertFrom(int version, InternalRow row)
static InternalRow	InternalRowUtils.copyInternalRow(InternalRow row, RowType rowType)
T	VersionedObjectSerializer.fromRow(InternalRow row)
abstract T	ObjectSerializer.fromRow(InternalRow rowData) Convert a InternalRow to T.
Integer	IntObjectSerializer.fromRow(InternalRow row)
KeyValue	KeyValueWithLevelNoReusingSerializer.fromRow(InternalRow row)
LinkedHashMap<String,String>	InternalRowPartitionComputer.generatePartValues(InternalRow in)
PartialRow	PartialRow.replace(InternalRow row)
OffsetRow	OffsetRow.replace(InternalRow row)
KeyProjectedRow	KeyProjectedRow.replaceRow(InternalRow row)
ProjectedRow	ProjectedRow.replaceRow(InternalRow row) Replaces the underlying InternalRow backing this ProjectedRow.
GenericRow	RowDataToObjectArrayConverter.toGenericRow(InternalRow rowData)

Method parameters in org.apache.paimon.utils with type arguments of type InternalRow

Modifier and Type	Method and Description
List<V>	ObjectsCache.read(K key, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<V>	ObjectsCache.read(K key, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<T>	ObjectsFile.read(String fileName, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
List<T>	ObjectsFile.read(String fileName, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter)
static <V> List<V>	ObjectsFile.readFromIterator(CloseableIterator<InternalRow> inputIterator, ObjectSerializer<V> serializer, Filter<InternalRow> readFilter)
static <V> List<V>	ObjectsFile.readFromIterator(CloseableIterator<InternalRow> inputIterator, ObjectSerializer<V> serializer, Filter<InternalRow> readFilter)

Constructors in org.apache.paimon.utils with parameters of type InternalRow

Constructor and Description
PartialRow(int arity, InternalRow row)

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

Constructor and Description
IteratorResultIterator(IteratorWithException<InternalRow,IOException> records, Runnable recycler, Path filePath, long pos)
ObjectsCache(SegmentsCache<K> cache, ObjectSerializer<V> projectedSerializer, RowType formatSchema, FunctionWithIOException<K,Long> fileSizeFunction, BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader)