Uses of Class
org.apache.paimon.data.BinaryRow

Packages that use BinaryRow

Package	Description
org.apache.paimon.append
org.apache.paimon.codegen
org.apache.paimon.crosspartition
org.apache.paimon.data
org.apache.paimon.data.serializer
org.apache.paimon.deletionvectors
org.apache.paimon.deletionvectors.append
org.apache.paimon.disk
org.apache.paimon.flink.lookup
org.apache.paimon.flink.query
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.source.align
org.apache.paimon.hive
org.apache.paimon.hive.migrate
org.apache.paimon.iceberg.manifest
org.apache.paimon.index
org.apache.paimon.io
org.apache.paimon.manifest
org.apache.paimon.mergetree
org.apache.paimon.metastore
org.apache.paimon.migrate
org.apache.paimon.operation
org.apache.paimon.operation.metrics
org.apache.paimon.partition
org.apache.paimon.query
org.apache.paimon.service.client
org.apache.paimon.service.messages
org.apache.paimon.sort
org.apache.paimon.stats
org.apache.paimon.table.query
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system
org.apache.paimon.utils

Uses of BinaryRow in org.apache.paimon.append

Methods in org.apache.paimon.append that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	UnawareAppendCompactionTask.partition()

Constructors in org.apache.paimon.append with parameters of type BinaryRow

Constructor and Description
MultiTableUnawareAppendCompactionTask(BinaryRow partition, List<DataFileMeta> files, Identifier identifier)
UnawareAppendCompactionTask(BinaryRow partition, List<DataFileMeta> files)

Uses of BinaryRow in org.apache.paimon.codegen

Methods in org.apache.paimon.codegen that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	Projection.apply(InternalRow row)

Uses of BinaryRow in org.apache.paimon.crosspartition

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

Modifier and Type	Method and Description
BinaryRow	KeyPartPartitionKeyExtractor.partition(InternalRow record)
BinaryRow	KeyPartPartitionKeyExtractor.trimmedPrimaryKey(InternalRow record)

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

Modifier and Type	Method and Description
CloseableIterator<BinaryRow>	GlobalIndexAssigner.endBoostrapWithoutEmit(boolean isEndInput)

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

Modifier and Type	Method and Description
int	BucketAssigner.assignBucket(BinaryRow part, Filter<Integer> filter, int maxCount)
void	BucketAssigner.bootstrapBucket(BinaryRow part, int bucket)
void	BucketAssigner.decrement(BinaryRow part, int bucket)
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)

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

Modifier and Type	Method and Description
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	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	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	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)
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)

Uses of BinaryRow in org.apache.paimon.data

Fields in org.apache.paimon.data declared as BinaryRow

Modifier and Type	Field and Description
static BinaryRow	BinaryRow.EMPTY_ROW

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

Modifier and Type	Method and Description
BinaryRow	BinaryRow.copy()
BinaryRow	BinaryRow.copy(BinaryRow reuse)
BinaryRow	PartitionInfo.getPartitionRow()
static BinaryRow	BinaryRow.singleColumn(BinaryString string)
static BinaryRow	BinaryRow.singleColumn(Integer i)
static BinaryRow	BinaryRow.singleColumn(String string)

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

Modifier and Type	Method and Description
BinaryRow	BinaryRow.copy(BinaryRow reuse)

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

Constructor and Description
BinaryRowWriter(BinaryRow row)
BinaryRowWriter(BinaryRow row, int initialSize)
PartitionInfo(int[] map, RowType partitionType, BinaryRow partition)

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

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

Modifier and Type	Method and Description
BinaryRow	BinaryRowSerializer.copy(BinaryRow from)
BinaryRow	BinaryRowSerializer.createInstance()
BinaryRow	BinaryRowSerializer.deserialize(BinaryRow reuse, DataInputView source)
BinaryRow	BinaryRowSerializer.deserialize(DataInputView source)
BinaryRow	BinaryRowSerializer.deserializeFromPages(AbstractPagedInputView headerLessView)
BinaryRow	BinaryRowSerializer.deserializeFromPages(BinaryRow reuse, AbstractPagedInputView headerLessView)
BinaryRow	BinaryRowSerializer.mapFromPages(BinaryRow reuse, AbstractPagedInputView headerLessView)
BinaryRow	BinaryRowSerializer.toBinaryRow(BinaryRow rowData)
BinaryRow	InternalRowSerializer.toBinaryRow(InternalRow row) Convert InternalRow into BinaryRow.
abstract BinaryRow	AbstractRowDataSerializer.toBinaryRow(T rowData) Convert a InternalRow to a BinaryRow.

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

Modifier and Type	Method and Description
BinaryRow	BinaryRowSerializer.copy(BinaryRow from)
BinaryRow	BinaryRowSerializer.deserialize(BinaryRow reuse, DataInputView source)
BinaryRow	BinaryRowSerializer.deserializeFromPages(BinaryRow reuse, AbstractPagedInputView headerLessView)
BinaryRow	BinaryRowSerializer.mapFromPages(BinaryRow reuse, AbstractPagedInputView headerLessView)
void	BinaryRowSerializer.pointTo(int length, BinaryRow reuse, AbstractPagedInputView headerLessView) Point row to memory segments with offset(in the AbstractPagedInputView) and length.
void	BinaryRowSerializer.serialize(BinaryRow record, DataOutputView target)
int	BinaryRowSerializer.serializeToPages(BinaryRow record, AbstractPagedOutputView headerLessView)
static void	BinaryRowSerializer.serializeWithoutLengthSlow(BinaryRow record, MemorySegmentWritable out)
BinaryRow	BinaryRowSerializer.toBinaryRow(BinaryRow rowData)

Uses of BinaryRow in org.apache.paimon.deletionvectors

Methods in org.apache.paimon.deletionvectors with parameters of type BinaryRow

Modifier and Type	Method and Description
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition)
DeletionVectorsMaintainer	DeletionVectorsMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition, int bucket)

Uses of BinaryRow in org.apache.paimon.deletionvectors.append

Methods in org.apache.paimon.deletionvectors.append that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	AppendDeletionFileMaintainer.getPartition()
BinaryRow	BucketedAppendDeletionFileMaintainer.getPartition()
BinaryRow	UnawareAppendDeletionFileMaintainer.getPartition()

Methods in org.apache.paimon.deletionvectors.append with parameters of type BinaryRow

Modifier and Type	Method and Description
static BucketedAppendDeletionFileMaintainer	AppendDeletionFileMaintainer.forBucketedAppend(IndexFileHandler indexFileHandler, Long snapshotId, BinaryRow partition, int bucket)
static UnawareAppendDeletionFileMaintainer	AppendDeletionFileMaintainer.forUnawareAppend(IndexFileHandler indexFileHandler, Long snapshotId, BinaryRow partition)

Uses of BinaryRow in org.apache.paimon.disk

Methods in org.apache.paimon.disk that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	RowBuffer.RowBufferIterator.getRow()
BinaryRow	ExternalBuffer.BufferIterator.getRow()
BinaryRow	ChannelReaderInputViewIterator.next()
BinaryRow	ChannelReaderInputViewIterator.next(BinaryRow reuse)

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

Modifier and Type	Method and Description
MutableObjectIterator<BinaryRow>	ChannelReaderInputView.createBinaryRowIterator(BinaryRowSerializer serializer)

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

Modifier and Type	Method and Description
BinaryRow	ChannelReaderInputViewIterator.next(BinaryRow reuse)

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

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

Modifier and Type	Method and Description
BinaryRow	FixedBucketFromPkExtractor.logPrimaryKey()
BinaryRow	FixedBucketFromPkExtractor.partition()
BinaryRow	DynamicPartitionLoader.partition()
BinaryRow	FixedBucketFromPkExtractor.trimmedPrimaryKey()

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

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

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

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

Methods in org.apache.paimon.flink.sink that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	RowDataKeyAndBucketExtractor.logPrimaryKey()
BinaryRow	StoreSinkWriteState.StateValue.partition()
BinaryRow	RowDataKeyAndBucketExtractor.partition()
BinaryRow	RowDataKeyAndBucketExtractor.trimmedPrimaryKey()

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

Modifier and Type	Method and Description
int	RowDataChannelComputer.channel(BinaryRow partition, int bucket)
void	StoreSinkWrite.compact(BinaryRow partition, int bucket, boolean fullCompaction)
void	GlobalFullCompactionSinkWrite.compact(BinaryRow partition, int bucket, boolean fullCompaction)
void	StoreSinkWriteImpl.compact(BinaryRow partition, int bucket, boolean fullCompaction)
boolean	StoreSinkWriteState.StateValueFilter.filter(String tableName, BinaryRow partition, int bucket)
void	StoreSinkWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)
void	StoreSinkWriteImpl.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)
DataFileMeta	RewriteFileIndexSink.FileIndexProcessor.process(BinaryRow partition, int bucket, DataFileMeta dataFileMeta)

Constructors in org.apache.paimon.flink.sink with parameters of type BinaryRow

Constructor and Description
StateValue(BinaryRow partition, int bucket, byte[] value)

Uses of BinaryRow in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	CdcRecordKeyAndBucketExtractor.logPrimaryKey()
BinaryRow	CdcRecordKeyAndBucketExtractor.partition()
BinaryRow	CdcRecordPartitionKeyExtractor.partition(CdcRecord record)
BinaryRow	CdcRecordKeyAndBucketExtractor.trimmedPrimaryKey()
BinaryRow	CdcRecordPartitionKeyExtractor.trimmedPrimaryKey(CdcRecord record)

Uses of BinaryRow in org.apache.paimon.flink.source.align

Methods in org.apache.paimon.flink.source.align that return BinaryRow

Modifier and Type	Method and Description
BinaryRow	PlaceholderSplit.partition()

Uses of BinaryRow in org.apache.paimon.hive

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

Modifier and Type	Method and Description
void	HiveMetastoreClient.addPartition(BinaryRow partition)

Uses of BinaryRow in org.apache.paimon.hive.migrate

Constructors in org.apache.paimon.hive.migrate with parameters of type BinaryRow

Constructor and Description
MigrateTask(FileIO fileIO, String format, String location, FileStoreTable paimonTable, BinaryRow partitionRow, Path newDir, Map<Path,Path> rollback)

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

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

Modifier and Type	Method and Description
BinaryRow	IcebergDataFileMeta.partition()

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

Modifier and Type	Method and Description
static IcebergDataFileMeta	IcebergDataFileMeta.create(IcebergDataFileMeta.Content content, String filePath, String fileFormat, BinaryRow partition, long recordCount, long fileSizeInBytes, TableSchema tableSchema, SimpleStats stats)

Uses of BinaryRow in org.apache.paimon.index

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

Modifier and Type	Method and Description
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(long snapshot, String indexType, Set<BinaryRow> partitions)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)

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

Modifier and Type	Method and Description
int	SimpleHashBucketAssigner.assign(BinaryRow partition, int hash)
int	BucketAssigner.assign(BinaryRow partition, int hash)
int	HashBucketAssigner.assign(BinaryRow partition, int hash) Assign a bucket for key hash of a record.
IndexMaintainer<T>	IndexMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition, int bucket)
IndexMaintainer<KeyValue>	HashIndexMaintainer.Factory.createOrRestore(Long snapshotId, BinaryRow partition, int bucket)
static PartitionIndex	PartitionIndex.loadIndex(IndexFileHandler indexFileHandler, BinaryRow partition, long targetBucketRowNumber, java.util.function.IntPredicate loadFilter, java.util.function.IntPredicate bucketFilter)
List<IndexFileMeta>	IndexFileHandler.scan(long snapshotId, String indexType, BinaryRow partition, int bucket)
Map<String,DeletionFile>	IndexFileHandler.scanDVIndex(Long snapshotId, BinaryRow partition, int bucket)
List<IndexManifestEntry>	IndexFileHandler.scanEntries(long snapshotId, String indexType, BinaryRow partition)
List<IndexManifestEntry>	IndexFileHandler.scanEntries(String indexType, BinaryRow partition)
Optional<IndexFileMeta>	IndexFileHandler.scanHashIndex(long snapshotId, BinaryRow partition, int bucket)

Method parameters in org.apache.paimon.index with type arguments of type BinaryRow

Modifier and Type	Method and Description
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(long snapshot, String indexType, Set<BinaryRow> partitions)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	IndexFileHandler.scan(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)
List<IndexManifestEntry>	IndexFileHandler.scanEntries(long snapshot, String indexType, Set<BinaryRow> partitions)
List<IndexManifestEntry>	IndexFileHandler.scanEntries(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)

Uses of BinaryRow in org.apache.paimon.io

Fields in org.apache.paimon.io declared as BinaryRow

Modifier and Type	Field and Description
static BinaryRow	DataFileMeta.EMPTY_MAX_KEY
static BinaryRow	DataFileMeta.EMPTY_MIN_KEY

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

Modifier and Type	Method and Description
BinaryRow	DataFileMeta.maxKey()
BinaryRow	DataFileMeta.minKey()

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

Modifier and Type	Method and Description
KeyValueFileWriterFactory	KeyValueFileWriterFactory.Builder.build(BinaryRow partition, int bucket, CoreOptions options)
KeyValueFileReaderFactory	KeyValueFileReaderFactory.Builder.build(BinaryRow partition, int bucket, DeletionVector.Factory dvFactory)
KeyValueFileReaderFactory	KeyValueFileReaderFactory.Builder.build(BinaryRow partition, int bucket, DeletionVector.Factory dvFactory, boolean projectKeys, List<Predicate> filters)

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

Constructor and Description
DataFileMeta(String fileName, long fileSize, long rowCount, BinaryRow minKey, BinaryRow maxKey, SimpleStats keyStats, SimpleStats valueStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, int level, List<String> extraFiles, Timestamp creationTime, Long deleteRowCount, byte[] embeddedIndex, FileSource fileSource)
DataFileMeta(String fileName, long fileSize, long rowCount, BinaryRow minKey, BinaryRow maxKey, SimpleStats keyStats, SimpleStats valueStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, int level, Long deleteRowCount, byte[] embeddedIndex, FileSource fileSource)

Uses of BinaryRow in org.apache.paimon.manifest

Fields in org.apache.paimon.manifest declared as BinaryRow

Modifier and Type	Field and Description
BinaryRow	FileEntry.Identifier.partition

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

Modifier and Type	Method and Description
BinaryRow	SimpleFileEntry.maxKey()
BinaryRow	FileEntry.maxKey()
BinaryRow	ManifestEntry.maxKey()
BinaryRow	SimpleFileEntry.minKey()
BinaryRow	FileEntry.minKey()
BinaryRow	ManifestEntry.minKey()
BinaryRow	IndexManifestEntry.partition()
BinaryRow	PartitionEntry.partition()
BinaryRow	SimpleFileEntry.partition()
BinaryRow	BucketEntry.partition()
BinaryRow	FileEntry.partition()
BinaryRow	ManifestEntry.partition()

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

Modifier and Type	Method and Description
static java.util.function.Function<InternalRow,BinaryRow>	ManifestEntrySerializer.partitionGetter()

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

Modifier and Type	Method and Description
boolean	ManifestCacheFilter.test(BinaryRow partition, int bucket)

Method parameters in org.apache.paimon.manifest with type arguments of type BinaryRow

Modifier and Type	Method and Description
static void	BucketEntry.merge(Collection<BucketEntry> from, Map<Pair<BinaryRow,Integer>,BucketEntry> to)
static void	PartitionEntry.merge(Collection<PartitionEntry> from, Map<BinaryRow,PartitionEntry> to)

Constructors in org.apache.paimon.manifest with parameters of type BinaryRow

Constructor and Description
BucketEntry(BinaryRow partition, int bucket, long recordCount, long fileSizeInBytes, long fileCount, long lastFileCreationTime)
Identifier(BinaryRow partition, int bucket, int level, String fileName, List<String> extraFiles, byte[] embeddedIndex)
IndexManifestEntry(FileKind kind, BinaryRow partition, int bucket, IndexFileMeta indexFile)
ManifestEntry(FileKind kind, BinaryRow partition, int bucket, int totalBuckets, DataFileMeta file)
PartitionEntry(BinaryRow partition, long recordCount, long fileSizeInBytes, long fileCount, long lastFileCreationTime)
SimpleFileEntry(FileKind kind, BinaryRow partition, int bucket, int level, String fileName, List<String> extraFiles, byte[] embeddedIndex, BinaryRow minKey, BinaryRow maxKey)

Uses of BinaryRow in org.apache.paimon.mergetree

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

Modifier and Type	Method and Description
static String	LookupFile.localFilePrefix(RowType partitionType, BinaryRow partition, int bucket, String remoteFileName)

Uses of BinaryRow in org.apache.paimon.metastore

Methods in org.apache.paimon.metastore with parameters of type BinaryRow

Modifier and Type	Method and Description
void	MetastoreClient.addPartition(BinaryRow partition)

Uses of BinaryRow in org.apache.paimon.migrate

Methods in org.apache.paimon.migrate that return BinaryRow

Modifier and Type	Method and Description
static BinaryRow	FileMetaUtils.writePartitionValue(RowType partitionRowType, Map<String,String> partitionValues, List<BinaryWriter.ValueSetter> valueSetters, String partitionDefaultName)

Methods in org.apache.paimon.migrate with parameters of type BinaryRow

Modifier and Type	Method and Description
static CommitMessage	FileMetaUtils.commitFile(BinaryRow partition, List<DataFileMeta> dataFileMetas)

Uses of BinaryRow in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as BinaryRow

Modifier and Type	Field and Description
protected BinaryRow	FileStoreWrite.State.partition

Fields in org.apache.paimon.operation with type parameters of type BinaryRow

Modifier and Type	Field and Description
protected Map<BinaryRow,Set<Integer>>	FileDeletionBase.deletionBuckets
protected Map<BinaryRow,Map<Integer,AbstractFileStoreWrite.WriterContainer<T>>>	AbstractFileStoreWrite.writers

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

Modifier and Type	Method and Description
Map<BinaryRow,List<Integer>>	AbstractFileStoreWrite.getActiveBuckets()
static Map<BinaryRow,Map<Integer,List<DataFileMeta>>>	FileStoreScan.Plan.groupByPartFiles(List<ManifestEntry> files) Return a map group by partition and bucket.
default List<BinaryRow>	FileStoreScan.listPartitions()

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

Modifier and Type	Method and Description
void	FileStoreWrite.compact(BinaryRow partition, int bucket, boolean fullCompaction) Compact data stored in given partition and bucket.
void	AbstractFileStoreWrite.compact(BinaryRow partition, int bucket, boolean fullCompaction)
List<DataFileMeta>	AppendOnlyFileStoreWrite.compactRewrite(BinaryRow partition, int bucket, java.util.function.Function<String,DeletionVector> dvFactory, List<DataFileMeta> toCompact)
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)
protected RecordWriter<InternalRow>	AppendOnlyFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected MergeTreeWriter	KeyValueFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected abstract RecordWriter<T>	AbstractFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer deletionVectorsMaintainer)
AbstractFileStoreWrite.WriterContainer<T>	AbstractFileStoreWrite.createWriterContainer(BinaryRow partition, int bucket, boolean ignorePreviousFiles)
protected AbstractFileStoreWrite.WriterContainer<T>	AbstractFileStoreWrite.getWriterWrapper(BinaryRow partition, int bucket)
void	FileStoreWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files) Notify that some new files are created at given snapshot in given bucket.
void	AbstractFileStoreWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)
FileStoreScan	AbstractFileStoreScan.withPartitionBucket(BinaryRow partition, int bucket)
FileStoreScan	FileStoreScan.withPartitionBucket(BinaryRow partition, int bucket)
void	FileStoreWrite.write(BinaryRow partition, int bucket, T data) Write the data to the store according to the partition and bucket.
void	AbstractFileStoreWrite.write(BinaryRow partition, int bucket, T data)
void	AppendOnlyFileStoreWrite.writeBundle(BinaryRow partition, int bucket, BundleRecords bundle)
void	BundleFileStoreWriter.writeBundle(BinaryRow partition, int bucket, BundleRecords bundle) Write the batch data to the store according to the partition and bucket.

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

Modifier and Type	Method and Description
protected void	FileDeletionBase.addMergedDataFiles(Map<BinaryRow,Map<Integer,Set<String>>> dataFiles, Snapshot snapshot) NOTE: This method is used for building data file skipping set.
protected boolean	FileDeletionBase.containsDataFile(Map<BinaryRow,Map<Integer,Set<String>>> dataFiles, ManifestEntry testee)
boolean	PartitionExpire.isValueAllExpired(Collection<BinaryRow> partitions)
FileStoreScan	AbstractFileStoreScan.withPartitionFilter(List<BinaryRow> partitions)
FileStoreScan	FileStoreScan.withPartitionFilter(List<BinaryRow> partitions)

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

Constructor and Description
State(BinaryRow partition, int bucket, long baseSnapshotId, long lastModifiedCommitIdentifier, Collection<DataFileMeta> dataFiles, long maxSequenceNumber, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, CommitIncrement commitIncrement)

Uses of BinaryRow in org.apache.paimon.operation.metrics

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

Modifier and Type	Method and Description
protected static Map<BinaryRow,Set<Integer>>	CommitStats.changedPartBuckets(List<ManifestEntry>... changes)
protected static List<BinaryRow>	CommitStats.changedPartitions(List<ManifestEntry>... changes)

Methods in org.apache.paimon.operation.metrics with parameters of type BinaryRow

Modifier and Type	Method and Description
CompactionMetrics.Reporter	CompactionMetrics.createReporter(BinaryRow partition, int bucket)

Uses of BinaryRow in org.apache.paimon.partition

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

Modifier and Type	Method and Description
Object[]	PartitionExpireStrategy.convertPartition(BinaryRow partition)
static PartitionInfo	PartitionUtils.create(Pair<int[],RowType> pair, BinaryRow binaryRow)
static Predicate	PartitionPredicate.createPartitionPredicate(RowType partitionType, BinaryRow partition)
boolean	PartitionValuesTimeExpireStrategy.isExpired(java.time.LocalDateTime expireDateTime, BinaryRow partition)
boolean	PartitionPredicate.test(BinaryRow part)
boolean	PartitionPredicate.DefaultPartitionPredicate.test(BinaryRow part)
boolean	PartitionPredicate.MultiplePartitionPredicate.test(BinaryRow part)

Method parameters in org.apache.paimon.partition with type arguments of type BinaryRow

Modifier and Type	Method and Description
static PartitionPredicate	PartitionPredicate.fromMultiple(RowType partitionType, List<BinaryRow> partitions)
static PartitionPredicate	PartitionPredicate.fromMultiple(RowType partitionType, Set<BinaryRow> partitions)

Uses of BinaryRow in org.apache.paimon.query

Methods in org.apache.paimon.query with parameters of type BinaryRow

Modifier and Type	Method and Description
InetSocketAddress	QueryLocationImpl.getLocation(BinaryRow partition, int bucket, boolean forceUpdate)
InetSocketAddress	QueryLocation.getLocation(BinaryRow partition, int bucket, boolean forceUpdate) Get location from partition and bucket.

Uses of BinaryRow in org.apache.paimon.service.client

Methods in org.apache.paimon.service.client with parameters of type BinaryRow

Modifier and Type	Method and Description
CompletableFuture<BinaryRow[]>	KvQueryClient.getValues(BinaryRow partition, int bucket, BinaryRow[] keys)
CompletableFuture<BinaryRow[]>	KvQueryClient.getValues(BinaryRow partition, int bucket, BinaryRow[] keys)

Uses of BinaryRow in org.apache.paimon.service.messages

Methods in org.apache.paimon.service.messages that return BinaryRow

Modifier and Type	Method and Description
BinaryRow[]	KvRequest.keys()
BinaryRow	KvRequest.partition()
BinaryRow[]	KvResponse.values()

Constructors in org.apache.paimon.service.messages with parameters of type BinaryRow

Constructor and Description
KvRequest(BinaryRow partition, int bucket, BinaryRow[] keys)
KvRequest(BinaryRow partition, int bucket, BinaryRow[] keys)
KvResponse(BinaryRow[] values)

Uses of BinaryRow in org.apache.paimon.sort

Fields in org.apache.paimon.sort declared as BinaryRow

Modifier and Type	Field and Description
protected BinaryRow	BinaryIndexedSortable.row1

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

Modifier and Type	Method and Description
protected MutableObjectIterator<BinaryRow>	BinaryExternalMerger.channelReaderInputViewIterator(ChannelReaderInputView inView)
protected Comparator<BinaryRow>	BinaryExternalMerger.mergeComparator()
protected List<BinaryRow>	BinaryExternalMerger.mergeReusedEntries(int size)
MutableObjectIterator<BinaryRow>	BinaryExternalSortBuffer.sortedIterator()
MutableObjectIterator<BinaryRow>	BinaryInMemorySortBuffer.sortedIterator()
MutableObjectIterator<BinaryRow>	SortBuffer.sortedIterator()

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

Modifier and Type	Method and Description
void	BinaryExternalSortBuffer.write(MutableObjectIterator<BinaryRow> iterator)
protected void	BinaryExternalMerger.writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator, AbstractPagedOutputView output)

Uses of BinaryRow in org.apache.paimon.stats

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

Modifier and Type	Method and Description
BinaryRow	SimpleStats.maxValues()
BinaryRow	SimpleStats.minValues()

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

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

Constructors in org.apache.paimon.stats with parameters of type BinaryRow

Constructor and Description
SimpleStats(BinaryRow minValues, BinaryRow maxValues, BinaryArray nullCounts)

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

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

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.
void	LocalTableQuery.refreshFiles(BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)

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

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

Modifier and Type	Method and Description
BinaryRow	TableWrite.getPartition(InternalRow row) Calculate which partition row belongs to.
BinaryRow	TableWriteImpl.getPartition(InternalRow row)
BinaryRow	KeyAndBucketExtractor.logPrimaryKey()
BinaryRow	RowKeyExtractor.logPrimaryKey()
BinaryRow	KeyAndBucketExtractor.partition()
BinaryRow	RowKeyExtractor.partition()
BinaryRow	CommitMessageImpl.partition()
BinaryRow	CommitMessage.partition() Partition of this commit message.
BinaryRow	SinkRecord.partition()
BinaryRow	RowPartitionKeyExtractor.partition(InternalRow record)
BinaryRow	PartitionKeyExtractor.partition(T record)
BinaryRow	SinkRecord.primaryKey()
BinaryRow	KeyAndBucketExtractor.trimmedPrimaryKey()
BinaryRow	RowKeyExtractor.trimmedPrimaryKey()
BinaryRow	RowPartitionKeyExtractor.trimmedPrimaryKey(InternalRow record)
BinaryRow	PartitionKeyExtractor.trimmedPrimaryKey(T record)

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

Modifier and Type	Method and Description
static int	KeyAndBucketExtractor.bucketKeyHashCode(BinaryRow bucketKey)
void	TableWrite.compact(BinaryRow partition, int bucket, boolean fullCompaction) Compact a bucket of a partition.
void	TableWriteImpl.compact(BinaryRow partition, int bucket, boolean fullCompaction)
void	TableWriteImpl.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files) Notify that some new files are created at given snapshot in given bucket.
static int	ChannelComputer.select(BinaryRow partition, int bucket, int numChannels)
void	TableWrite.writeBundle(BinaryRow partition, int bucket, BundleRecords bundle) Write a bundle records directly, not per row.
void	TableWriteImpl.writeBundle(BinaryRow partition, int bucket, BundleRecords bundle)

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

Constructor and Description
CommitMessageImpl(BinaryRow partition, int bucket, DataIncrement dataIncrement, CompactIncrement compactIncrement)
CommitMessageImpl(BinaryRow partition, int bucket, DataIncrement dataIncrement, CompactIncrement compactIncrement, IndexIncrement indexIncrement)
SinkRecord(BinaryRow partition, int bucket, BinaryRow primaryKey, InternalRow row)

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

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

Modifier and Type	Method and Description
BinaryRow	DataSplit.partition()

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

Modifier and Type	Method and Description
default List<BinaryRow>	TableScan.listPartitions() List partitions.

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

Modifier and Type	Method and Description
DataSplit.Builder	DataSplit.Builder.withPartition(BinaryRow partition)

Method parameters in org.apache.paimon.table.source with type arguments of type BinaryRow

Modifier and Type	Method and Description
AbstractDataTableScan	AbstractDataTableScan.withPartitionFilter(List<BinaryRow> partitions)
default InnerTableScan	InnerTableScan.withPartitionFilter(List<BinaryRow> partitions)

Uses of BinaryRow in org.apache.paimon.table.source.snapshot

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

Modifier and Type	Method and Description
List<BinaryRow>	SnapshotReader.partitions() List partitions.
List<BinaryRow>	SnapshotReaderImpl.partitions()

Method parameters in org.apache.paimon.table.source.snapshot with type arguments of type BinaryRow

Modifier and Type	Method and Description
SnapshotReader	SnapshotReader.withPartitionFilter(List<BinaryRow> partitions)
SnapshotReader	SnapshotReaderImpl.withPartitionFilter(List<BinaryRow> partitions)

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

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

Modifier and Type	Method and Description
BinaryRow	FileMonitorTable.FileChange.partition()

Constructors in org.apache.paimon.table.system with parameters of type BinaryRow

Constructor and Description
FileChange(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)

Uses of BinaryRow in org.apache.paimon.utils

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

Modifier and Type	Field and Description
static BinaryRow	BinaryRowDataUtil.EMPTY_ROW

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

Modifier and Type	Method and Description
static BinaryRow	SerializationUtils.deserializeBinaryRow(byte[] bytes) Schemaless deserialization for BinaryRow.
static BinaryRow	SerializationUtils.deserializeBinaryRow(DataInputView input) Schemaless deserialization for BinaryRow from a DataInputView.

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

Modifier and Type	Method and Description
InternalRow	ProjectToRowFunction.apply(InternalRow input, BinaryRow project)
Path	FileStorePathFactory.bucketPath(BinaryRow partition, int bucket)
DataFilePathFactory	FileStorePathFactory.createDataFilePathFactory(BinaryRow partition, int bucket)
static ColumnVector	VectorMappingUtils.createFixedVector(DataType dataType, BinaryRow partition, int index)
List<Path>	FileStorePathFactory.getHierarchicalPartitionPath(BinaryRow partition)
String	FileStorePathFactory.getPartitionString(BinaryRow partition) IMPORTANT: This method is NOT THREAD SAFE.
static String	InternalRowPartitionComputer.partToSimpleString(RowType partitionType, BinaryRow partition, String delimiter, int maxLength)
Path	FileStorePathFactory.relativePartitionAndBucketPath(BinaryRow partition, int bucket)
static byte[]	SerializationUtils.serializeBinaryRow(BinaryRow row) Serialize BinaryRow, the difference between this and BinaryRowSerializer is that arity is also serialized here, so the deserialization is schemaless.
static void	SerializationUtils.serializeBinaryRow(BinaryRow row, DataOutputView out) Serialize BinaryRow to a DataOutputView.