| 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) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.