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 CommitCallbackafterNumCommits(int numCommits, CommitCallback delegate)Create newCommitCallbackthat will commit the delegate afternumCommitssuccessful commits as successful, or after first error as failedvoidcommit(boolean success, java.lang.Throwable error)Commit the ingest process.static CommitCallbacknoop()
-
-
-
Method Detail
-
afterNumCommits
static CommitCallback afterNumCommits(int numCommits, CommitCallback delegate)
Create newCommitCallbackthat will commit the delegate afternumCommitssuccessful 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-trueis the write was successful,falseotherwiseerror- the error that was throws during the processing.
-
-