File tree Expand file tree Collapse file tree
flink-core/src/main/java/org/apache/flink/api/connector/sink2 Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3838@ Public
3939public interface Committer <CommT > extends AutoCloseable {
4040 /**
41- * Commit the given list of {@link CommT }.
41+ * Commit the given collection of {@link CommitRequest }.
4242 *
43- * @param committables A list of commit requests staged by the sink writer.
43+ * @param committables A collection of commit requests staged by the sink writer.
4444 * @throws IOException for reasons that may yield a complete restart of the job.
4545 */
4646 void commit (Collection <CommitRequest <CommT >> committables )
@@ -49,7 +49,7 @@ void commit(Collection<CommitRequest<CommT>> committables)
4949 /**
5050 * A request to commit a specific committable.
5151 *
52- * @param <CommT>
52+ * @param <CommT> The type of information needed to commit the staged data
5353 */
5454 @ Public
5555 interface CommitRequest <CommT > {
You can’t perform that action at this time.
0 commit comments