| Interface | Description |
|---|---|
| ExistingProcessor |
Processor to process existing key.
|
| Class | Description |
|---|---|
| BucketAssigner |
Bucket Assigner to assign bucket in a partition.
|
| DeleteExistingProcessor |
A
ExistingProcessor to delete old record. |
| GlobalIndexAssigner |
Assign UPDATE_BEFORE and bucket for the input record, output record with bucket.
|
| IndexBootstrap |
Bootstrap key index from Paimon table.
|
| KeyPartPartitionKeyExtractor |
A
PartitionKeyExtractor to InternalRow with only key and partition fields. |
| SkipNewExistingProcessor |
A
ExistingProcessor to skip new record. |
| UseOldExistingProcessor |
A
ExistingProcessor to use old partition and bucket. |
| Enum | Description |
|---|---|
| ExistingProcessor.SortOrder |
Input Order for sorting.
|
| KeyPartOrRow |
Type of record, key or full row.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.