Modifier and Type | Method and Description |
---|---|
void |
Committer.commit(Collection<Committer.CommitRequest<CommT>> committables)
Commit the given list of
CommT . |
Modifier and Type | Method and Description |
---|---|
void |
FileCommitter.commit(Collection<Committer.CommitRequest<FileSinkCommittable>> requests) |
Modifier and Type | Method and Description |
---|---|
void |
PulsarCommitter.commit(Collection<Committer.CommitRequest<PulsarCommittable>> requests) |
Modifier and Type | Method and Description |
---|---|
void |
SinkV1Adapter.GlobalCommitterAdapter.commit(Collection<Committer.CommitRequest<CommT>> committables) |
Modifier and Type | Class and Description |
---|---|
class |
CommitRequestImpl<CommT>
Internal implementation to commit a specific committable and handle the response.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.