CommT
- The type of information needed to commit the staged dataCommitter
.@Deprecated @PublicEvolving public interface Committer<CommT> extends AutoCloseable
Committer
is responsible for committing the data staged by the sink.Modifier and Type | Method and Description |
---|---|
List<CommT> |
commit(List<CommT> committables)
Deprecated.
Commits the given list of
CommT and returns a list of CommT that need to be
re-committed. |
close
List<CommT> commit(List<CommT> committables) throws IOException, InterruptedException
CommT
and returns a list of CommT
that need to be
re-committed. The elements of the return list must be a subset of the input list, so that
successful committables can be inferred.committables
- A list of information needed to commit data staged by the sink.CommT
that need to be re-committed.IOException
- if the commit operation fail and do not want to retry any more.InterruptedException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.