CommT- The type of information needed to commit the staged data
@Deprecated @PublicEvolving public interface Committer<CommT> extends AutoCloseable
Committeris responsible for committing the data staged by the sink.
|Modifier and Type||Method and Description|
Commits the given list of
List<CommT> commit(List<CommT> committables) throws IOException, InterruptedException
CommTand returns a list of
CommTthat 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.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.