Package | Description |
---|---|
org.apache.paimon.crosspartition |
Modifier and Type | Method and Description |
---|---|
static ExistingProcessor |
ExistingProcessor.create(CoreOptions.MergeEngine mergeEngine,
ProjectToRowFunction setPartition,
BucketAssigner bucketAssigner,
java.util.function.BiConsumer<InternalRow,Integer> collector) |
Constructor and Description |
---|
DeleteExistingProcessor(ProjectToRowFunction setPartition,
BucketAssigner bucketAssigner,
java.util.function.BiConsumer<InternalRow,Integer> collector) |
UseOldExistingProcessor(ProjectToRowFunction setPartition,
java.util.function.BiConsumer<InternalRow,Integer> collector) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.