Uses of Interface
org.apache.paimon.utils.FieldsComparator

Packages that use FieldsComparator

Package	Description
org.apache.paimon.flink.lookup
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.mergetree.localmerge
org.apache.paimon.operation
org.apache.paimon.utils

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

Fields in org.apache.paimon.flink.lookup declared as FieldsComparator

Modifier and Type	Field and Description
protected FieldsComparator	FullCacheLookupTable.userDefinedSeqComparator

Uses of FieldsComparator in org.apache.paimon.mergetree

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

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

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

Constructor and Description
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)
SortBufferWriteBuffer(RowType keyType, RowType valueType, FieldsComparator userDefinedSeqComparator, MemorySegmentPool memoryPool, boolean spillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions compression, IOManager ioManager)

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

Fields in org.apache.paimon.mergetree.compact declared as FieldsComparator

Modifier and Type	Field and Description
protected FieldsComparator	MergeTreeCompactRewriter.userDefinedSeqComparator

Methods in org.apache.paimon.mergetree.compact with parameters of type FieldsComparator

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)

Constructors in org.apache.paimon.mergetree.compact with parameters of type FieldsComparator

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)
FullChangelogMergeTreeCompactRewriter(int maxLevel, CoreOptions.MergeEngine mergeEngine, FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter, RecordEqualiser valueEqualiser)
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)
MergeTreeCompactRewriter(FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter)
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)

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

Constructor and Description
PartialUpdateMergeFunction(InternalRow.FieldGetter[] getters, boolean ignoreDelete, Map<Integer,FieldsComparator> fieldSeqComparators, Map<Integer,FieldAggregator> fieldAggregators, boolean fieldSequenceEnabled, boolean removeRecordOnDelete, Set<Integer> sequenceGroupPartialDelete)

Uses of FieldsComparator in org.apache.paimon.mergetree.localmerge

Constructors in org.apache.paimon.mergetree.localmerge with parameters of type FieldsComparator

Constructor and Description
HashMapLocalMerger(RowType rowType, List<String> primaryKeys, MemorySegmentPool memoryPool, MergeFunction<KeyValue> mergeFunction, FieldsComparator userDefinedSeqComparator)

Uses of FieldsComparator in org.apache.paimon.operation

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

Constructor and Description

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)

Uses of FieldsComparator in org.apache.paimon.utils

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

Modifier and Type	Class and Description
class	UserDefinedSeqComparator A FieldsComparator for user defined sequence fields.