Package | Description |
---|---|
org.apache.paimon.flink.sink.partition | |
org.apache.paimon.partition.actions | |
org.apache.paimon.spark.procedure |
Modifier and Type | Method and Description |
---|---|
static void |
PartitionMarkDone.markDone(List<String> partitions,
List<PartitionMarkDoneAction> actions) |
Constructor and Description |
---|
PartitionMarkDone(InternalRowPartitionComputer partitionComputer,
PartitionMarkDoneTrigger trigger,
List<PartitionMarkDoneAction> actions,
boolean waitCompaction) |
Modifier and Type | Class and Description |
---|---|
class |
AddDonePartitionAction
A
PartitionMarkDoneAction which add ".done" partition. |
class |
MarkPartitionDoneEventAction
A
PartitionMarkDoneAction which add mark "PartitionEventType.LOAD_DONE". |
class |
SuccessFileMarkDoneAction
A
PartitionMarkDoneAction which create "_SUCCESS" file. |
Modifier and Type | Method and Description |
---|---|
static List<PartitionMarkDoneAction> |
PartitionMarkDoneAction.createActions(FileStoreTable fileStoreTable,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
static void |
MarkPartitionDoneProcedure.markDone(List<String> partitions,
List<PartitionMarkDoneAction> actions) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.