FlinkGlobalCommitter (SeaTunnel : Translation : Flink : Common 2.3.7 API)

java.lang.Object
- org.apache.seatunnel.translation.flink.sink.FlinkGlobalCommitter<CommT,GlobalCommT>

类型参数:

CommT - The generic type of commit message type

GlobalCommT - The generic type of global commit message type

所有已实现的接口:

AutoCloseable, org.apache.flink.api.connector.sink.GlobalCommitter<CommitWrapper<CommT>,GlobalCommT>
```
public class FlinkGlobalCommitter<CommT,GlobalCommT>
extends Object
implements org.apache.flink.api.connector.sink.GlobalCommitter<CommitWrapper<CommT>,GlobalCommT>
```
The committer wrapper of SinkAggregatedCommitter, which is created by Sink.createGlobalCommitter(), used to unify the different implementations of SinkAggregatedCommitter

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`close()`
`GlobalCommT`	`combine(List<CommitWrapper<CommT>> committables)`
`List<GlobalCommT>`	`commit(List<GlobalCommT> globalCommittables)`
`void`	`endOfInput()`
`List<GlobalCommT>`	`filterRecoveredCommittables(List globalCommittables)`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 方法详细资料
  - filterRecoveredCommittables
```
public List<GlobalCommT> filterRecoveredCommittables(List globalCommittables)
                                              throws IOException
```
    指定者:
    
    filterRecoveredCommittables 在接口中 org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT>
    
    抛出:
    
    IOException
  - combine
```
public GlobalCommT combine(List<CommitWrapper<CommT>> committables)
                    throws IOException
```
    指定者:
    
    combine 在接口中 org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT>
    
    抛出:
    
    IOException
  - commit
```
public List<GlobalCommT> commit(List<GlobalCommT> globalCommittables)
                         throws IOException
```
    指定者:
    
    commit 在接口中 org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT>
    
    抛出:
    
    IOException
  - endOfInput
```
public void endOfInput()
                throws IOException
```
    指定者:
    
    endOfInput 在接口中 org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT>
    
    抛出:
    
    IOException
  - close
```
public void close()
           throws Exception
```
    指定者:
    
    close 在接口中 AutoCloseable
    
    抛出:
    
    Exception