Uses of Interface
org.apache.paimon.mergetree.compact.MergeFunctionFactory

Packages that use MergeFunctionFactory

Package	Description
org.apache.paimon
org.apache.paimon.mergetree.compact
org.apache.paimon.mergetree.compact.aggregate
org.apache.paimon.operation
org.apache.paimon.table

Uses of MergeFunctionFactory in org.apache.paimon

Constructors in org.apache.paimon with parameters of type MergeFunctionFactory

Constructor and Description
KeyValueFileStore(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, boolean crossPartitionUpdate, CoreOptions options, RowType partitionType, RowType bucketKeyType, RowType keyType, RowType valueType, KeyValueFieldsExtractor keyValueFieldsExtractor, MergeFunctionFactory<KeyValue> mfFactory, String tableName, CatalogEnvironment catalogEnvironment)

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

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

Modifier and Type	Field and Description
protected MergeFunctionFactory<KeyValue>	MergeTreeCompactRewriter.mfFactory

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

Modifier and Type	Method and Description
static MergeFunctionFactory<KeyValue>	DeduplicateMergeFunction.factory()
static MergeFunctionFactory<KeyValue>	DeduplicateMergeFunction.factory(Options options)
static MergeFunctionFactory<KeyValue>	PartialUpdateMergeFunction.factory(Options options, RowType rowType, List<String> primaryKeys)
static MergeFunctionFactory<KeyValue>	FirstRowMergeFunction.factory(Options options, RowType keyType, RowType valueType)
static MergeFunctionFactory<KeyValue>	LookupMergeFunction.wrap(MergeFunctionFactory<KeyValue> wrapped, RowType keyType, RowType valueType)

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

Modifier and Type	Method and Description
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.FirstRowMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<Boolean> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.MergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
MergeFunctionWrapper<ChangelogResult>	LookupMergeTreeCompactRewriter.LookupMergeFunctionWrapperFactory.create(MergeFunctionFactory<KeyValue> mfFactory, int outputLevel, LookupLevels<T> lookupLevels, DeletionVectorsMaintainer deletionVectorsMaintainer)
static MergeFunctionFactory<KeyValue>	LookupMergeFunction.wrap(MergeFunctionFactory<KeyValue> wrapped, RowType keyType, RowType valueType)

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

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)
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)
MergeTreeCompactRewriter(FileReaderFactory<KeyValue> readerFactory, KeyValueFileWriterFactory writerFactory, Comparator<InternalRow> keyComparator, FieldsComparator userDefinedSeqComparator, MergeFunctionFactory<KeyValue> mfFactory, MergeSorter mergeSorter)

Uses of MergeFunctionFactory in org.apache.paimon.mergetree.compact.aggregate

Methods in org.apache.paimon.mergetree.compact.aggregate that return MergeFunctionFactory

Modifier and Type	Method and Description
static MergeFunctionFactory<KeyValue>	AggregateMergeFunction.factory(Options conf, List<String> tableNames, List<DataType> tableTypes, List<String> primaryKeys)

Uses of MergeFunctionFactory in org.apache.paimon.operation

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

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)
MergeFileSplitRead(CoreOptions options, TableSchema schema, RowType keyType, RowType valueType, Comparator<InternalRow> keyComparator, MergeFunctionFactory<KeyValue> mfFactory, KeyValueFileReaderFactory.Builder readerFactoryBuilder)

Uses of MergeFunctionFactory in org.apache.paimon.table

Methods in org.apache.paimon.table that return MergeFunctionFactory

Modifier and Type	Method and Description
static MergeFunctionFactory<KeyValue>	PrimaryKeyTableUtils.createMergeFunctionFactory(TableSchema tableSchema, KeyValueFieldsExtractor extractor)