Package cz.o2.proxima.direct.core
Interface CommitCallback
-
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@Stable @FunctionalInterface public interface CommitCallback
Callback for write and commit log operations.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static CommitCallback
afterNumCommits(int numCommits, CommitCallback delegate)
Create newCommitCallback
that will commit the delegate afternumCommits
successful commits as successful, or after first error as failedvoid
commit(boolean success, java.lang.Throwable error)
Commit the ingest process.static CommitCallback
noop()
-
-
-
Method Detail
-
afterNumCommits
static CommitCallback afterNumCommits(int numCommits, CommitCallback delegate)
Create newCommitCallback
that will commit the delegate afternumCommits
successful commits as successful, or- after first error as failed
-
noop
static CommitCallback noop()
-
commit
void commit(boolean success, java.lang.Throwable error)
Commit the ingest process.- Parameters:
success
-true
is the write was successful,false
otherwiseerror
- the error that was throws during the processing.
-
-