Interface ResultHandler<T>

  • Type Parameters:
    T - Type of the request entries.

    @PublicEvolving
    public interface ResultHandler<T>
    Interface to handle the result of a AsyncSinkWriter request.
    • Method Detail

      • complete

        void complete()
        Mark the in-flight request as completed successfully.
      • completeExceptionally

        void completeExceptionally​(Exception e)
        Fail job with fatal exception.
      • retryForEntries

        void retryForEntries​(List<T> requestEntriesToRetry)
        Requeue Failed entries to retry.