org.apache.flink.connector.file.table

Class PartitionCommitPolicyFactory

java.lang.Object

org.apache.flink.connector.file.table.PartitionCommitPolicyFactory

All Implemented Interfaces:

Serializable

@Internal
public class PartitionCommitPolicyFactory
extends Object
implements Serializable

A factory to create PartitionCommitPolicy chain.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PartitionCommitPolicyFactory(String policyKind, String customClass, String successFileName)

Method Summary

Modifier and Type	Method and Description
List<PartitionCommitPolicy>	createPolicyChain(ClassLoader cl, java.util.function.Supplier<FileSystem> fsSupplier) Create a policy chain.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionCommitPolicyFactory

public PartitionCommitPolicyFactory(String policyKind,
                                    String customClass,
                                    String successFileName)

Method Detail

createPolicyChain

public List<PartitionCommitPolicy> createPolicyChain(ClassLoader cl,
                                                     java.util.function.Supplier<FileSystem> fsSupplier)

Create a policy chain.