CommT
- The type of information needed to commit the staged data@Experimental 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)
Commit the given list of
CommT . |
close
List<CommT> commit(List<CommT> committables) throws IOException
CommT
.committables
- A list of information needed to commit data staged by the sink.CommT
needed to re-commit, which is needed in case we implement a
"commit-with-retry" pattern.IOException
- if the commit operation fail and do not want to retry any more.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.