| Package | Description |
|---|---|
| org.apache.paimon.flink.sink.partition | |
| org.apache.paimon.manifest | |
| org.apache.paimon.metastore | |
| org.apache.paimon.utils |
| Constructor and Description |
|---|
PartitionMarkDone(InternalRowPartitionComputer partitionComputer,
PartitionMarkDoneTrigger trigger,
List<PartitionMarkDoneAction> actions,
boolean waitCompaction,
FlinkConnectorOptions.PartitionMarkDoneActionMode partitionMarkDoneActionMode) |
| Modifier and Type | Method and Description |
|---|---|
Partition |
PartitionEntry.toPartition(InternalRowPartitionComputer computer) |
PartitionStatistics |
PartitionEntry.toPartitionStatistics(InternalRowPartitionComputer computer) |
| Constructor and Description |
|---|
AddPartitionCommitCallback(PartitionHandler partitionHandler,
InternalRowPartitionComputer partitionComputer) |
| Modifier and Type | Method and Description |
|---|---|
static InternalRowPartitionComputer |
FileStorePathFactory.getPartitionComputer(RowType partitionType,
String defaultPartValue,
boolean legacyPartitionName) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.