Class ClientScrollableHitSource

    • Constructor Detail

      • ClientScrollableHitSource

        public ClientScrollableHitSource​(org.apache.logging.log4j.Logger logger,
                                         BackoffPolicy backoffPolicy,
                                         ThreadPool threadPool,
                                         java.lang.Runnable countSearchRetry,
                                         java.util.function.Consumer<java.lang.Exception> fail,
                                         ParentTaskAssigningClient client,
                                         SearchRequest firstSearchRequest)
    • Method Detail

      • clearScroll

        public void clearScroll​(java.lang.String scrollId,
                                java.lang.Runnable onCompletion)
        Description copied from class: ScrollableHitSource
        Called to clear a scroll id.
        Specified by:
        clearScroll in class ScrollableHitSource
        Parameters:
        scrollId - the id to clear
        onCompletion - implementers must call this after completing the clear whether they are successful or not
      • cleanup

        protected void cleanup​(java.lang.Runnable onCompletion)
        Description copied from class: ScrollableHitSource
        Called after the process has been totally finished to clean up any resources the process needed like remote connections.
        Specified by:
        cleanup in class ScrollableHitSource
        Parameters:
        onCompletion - implementers must call this after completing the cleanup whether they are successful or not