Package | Description |
---|---|
org.apache.paimon.crosspartition | |
org.apache.paimon.flink.sink.index |
Class and Description |
---|
BucketAssigner
Bucket Assigner to assign bucket in a partition.
|
ExistingProcessor
Processor to process existing key.
|
ExistingProcessor.SortOrder
Input Order for sorting.
|
KeyPartOrRow
Type of record, key or full row.
|
Class and Description |
---|
GlobalIndexAssigner
Assign UPDATE_BEFORE and bucket for the input record, output record with bucket.
|
IndexBootstrap
Bootstrap key index from Paimon table.
|
KeyPartOrRow
Type of record, key or full row.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.