类 FlinkGlobalCommitter<CommT,GlobalCommT>
- java.lang.Object
-
- org.apache.seatunnel.translation.flink.sink.FlinkGlobalCommitter<CommT,GlobalCommT>
-
- 类型参数:
CommT- The generic type of commit message typeGlobalCommT- 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 ofSinkAggregatedCommitter, which is created bySink.createGlobalCommitter(), used to unify the different implementations ofSinkAggregatedCommitter
-
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 voidclose()GlobalCommTcombine(List<CommitWrapper<CommT>> committables)List<GlobalCommT>commit(List<GlobalCommT> globalCommittables)voidendOfInput()List<GlobalCommT>filterRecoveredCommittables(List globalCommittables)
-
-
-
方法详细资料
-
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
-
-