Package | Description |
---|---|
org.apache.paimon.flink.sink.partition | |
org.apache.paimon.hive | |
org.apache.paimon.metastore | |
org.apache.paimon.operation | |
org.apache.paimon.partition.actions |
Constructor and Description |
---|
HmsReporter(FileStoreTable table,
MetastoreClient client) |
Modifier and Type | Class and Description |
---|---|
class |
HiveMetastoreClient
MetastoreClient for Hive tables. |
Modifier and Type | Method and Description |
---|---|
MetastoreClient |
HiveMetastoreClient.Factory.create() |
Modifier and Type | Method and Description |
---|---|
MetastoreClient |
MetastoreClient.Factory.create() |
Constructor and Description |
---|
AddPartitionCommitCallback(MetastoreClient client) |
AddPartitionTagCallback(MetastoreClient client,
String partitionField) |
Constructor and Description |
---|
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
MetastoreClient metastoreClient) |
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
MetastoreClient metastoreClient,
boolean endInputCheckPartitionExpire) |
Modifier and Type | Method and Description |
---|---|
static MetastoreClient |
PartitionMarkDoneAction.createMetastoreClient(FileStoreTable table,
CoreOptions options) |
Constructor and Description |
---|
AddDonePartitionAction(MetastoreClient metastoreClient) |
MarkPartitionDoneEventAction(MetastoreClient metastoreClient) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.