SuccessFileCommitPolicy (Flink : Connectors : Files 2.2.0 API)

java.lang.Object
- org.apache.flink.connector.file.table.SuccessFileCommitPolicy

All Implemented Interfaces:

PartitionCommitPolicy
```
@Internal
public class SuccessFileCommitPolicy
extends Object
implements PartitionCommitPolicy
```
Partition commit policy to add success file to directory. Success file is configurable and empty file.

- Nested Class Summary
  - Nested classes/interfaces inherited from interface org.apache.flink.connector.file.table.PartitionCommitPolicy
    PartitionCommitPolicy.Context
- Field Summary
  - Fields inherited from interface org.apache.flink.connector.file.table.PartitionCommitPolicy
    CUSTOM, METASTORE, SUCCESS_FILE
- Constructor Summary
  
  Constructors
  Constructor Description
  
  SuccessFileCommitPolicy(String fileName, org.apache.flink.core.fs.FileSystem fileSystem)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void commit(PartitionCommitPolicy.Context context)
  Commit a partition.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SuccessFileCommitPolicy

public SuccessFileCommitPolicy(String fileName,
                               org.apache.flink.core.fs.FileSystem fileSystem)

Method Detail
- commit
```
public void commit(PartitionCommitPolicy.Context context)
            throws Exception
```
  Description copied from interface: PartitionCommitPolicy
  
  Commit a partition.
  
  Specified by:
  
  commit in interface PartitionCommitPolicy
  
  Throws:
  
  Exception