Package 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	Description
PartitionCommitPolicyFactory(String policyKind, String customClass, String successFileName, List<String> parameters)

Method Summary

Modifier and Type	Method	Description
List<PartitionCommitPolicy>	createPolicyChain(ClassLoader cl, Supplier<org.apache.flink.core.fs.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,
                                    List<String> parameters)

Method Detail

createPolicyChain

public List<PartitionCommitPolicy> createPolicyChain(ClassLoader cl,
                                                     Supplier<org.apache.flink.core.fs.FileSystem> fsSupplier)

Create a policy chain.