Package | Description |
---|---|
org.apache.flink.table.filesystem |
Modifier and Type | Class and Description |
---|---|
class |
MetastoreCommitPolicy
Partition commit policy to update metastore.
|
class |
SuccessFileCommitPolicy
Partition commit policy to add success file to directory.
|
Modifier and Type | Method and Description |
---|---|
static List<PartitionCommitPolicy> |
PartitionCommitPolicy.createPolicyChain(ClassLoader cl,
String policyKind,
String customClass,
String successFileName,
java.util.function.Supplier<FileSystem> fsSupplier)
Create a policy chain from config.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.