Package | Description |
---|---|
org.apache.paimon.flink.sink.partition | |
org.apache.paimon.metastore | |
org.apache.paimon.operation | |
org.apache.paimon.partition.actions | |
org.apache.paimon.table |
Constructor and Description |
---|
PartitionStatisticsReporter(FileStoreTable table,
PartitionHandler partitionHandler) |
Constructor and Description |
---|
AddPartitionCommitCallback(PartitionHandler partitionHandler,
InternalRowPartitionComputer partitionComputer) |
AddPartitionTagCallback(PartitionHandler partitionHandler,
String partitionField) |
Constructor and Description |
---|
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
PartitionHandler partitionHandler,
boolean endInputCheckPartitionExpire,
int maxExpireNum) |
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
PartitionHandler partitionHandler,
int maxExpireNum) |
Modifier and Type | Method and Description |
---|---|
static PartitionHandler |
PartitionMarkDoneAction.createPartitionHandler(FileStoreTable table,
CoreOptions options) |
Constructor and Description |
---|
AddDonePartitionAction(PartitionHandler partitionHandler) |
MarkPartitionDoneEventAction(PartitionHandler partitionHandler) |
Modifier and Type | Method and Description |
---|---|
static PartitionHandler |
PartitionHandler.create(Catalog catalog,
Identifier identifier) |
PartitionHandler |
CatalogEnvironment.partitionHandler() |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.