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 Detail

      • afterNumCommits

        static CommitCallback afterNumCommits​(int numCommits,
                                              CommitCallback delegate)
        Create new CommitCallback that will commit the delegate after
        • numCommits successful commits as successful, or
        • after first error as failed
      • commit

        void commit​(boolean success,
                    java.lang.Throwable error)
        Commit the ingest process.
        Parameters:
        success - true is the write was successful, false otherwise
        error - the error that was throws during the processing.