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.