Package org.elasticsearch.index.reindex
Class ClientScrollableHitSource
java.lang.Object
org.elasticsearch.index.reindex.ScrollableHitSource
org.elasticsearch.index.reindex.ClientScrollableHitSource
A scrollable source of hits from a Client instance.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
ScrollableHitSource.AsyncResponse, ScrollableHitSource.BasicHit, ScrollableHitSource.Hit, ScrollableHitSource.Response, ScrollableHitSource.SearchFailure
-
Field Summary
Fields inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
backoffPolicy, countSearchRetry, fail, logger, threadPool
-
Constructor Summary
ConstructorDescriptionClientScrollableHitSource
(org.apache.logging.log4j.Logger logger, BackoffPolicy backoffPolicy, ThreadPool threadPool, Runnable countSearchRetry, Consumer<ScrollableHitSource.AsyncResponse> onResponse, Consumer<Exception> fail, ParentTaskAssigningClient client, SearchRequest firstSearchRequest) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
Called after the process has been totally finished to clean up any resources the process needed like remote connections.void
clearScroll
(String scrollId, Runnable onCompletion) Called to clear a scroll id.void
doStart
(RejectAwareActionListener<ScrollableHitSource.Response> searchListener) protected void
doStartNextScroll
(String scrollId, TimeValue extraKeepAlive, RejectAwareActionListener<ScrollableHitSource.Response> searchListener) Methods inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
close, setScroll, start, startNextScroll
-
Constructor Details
-
ClientScrollableHitSource
public ClientScrollableHitSource(org.apache.logging.log4j.Logger logger, BackoffPolicy backoffPolicy, ThreadPool threadPool, Runnable countSearchRetry, Consumer<ScrollableHitSource.AsyncResponse> onResponse, Consumer<Exception> fail, ParentTaskAssigningClient client, SearchRequest firstSearchRequest)
-
-
Method Details
-
doStart
- Specified by:
doStart
in classScrollableHitSource
-
doStartNextScroll
protected void doStartNextScroll(String scrollId, TimeValue extraKeepAlive, RejectAwareActionListener<ScrollableHitSource.Response> searchListener) - Specified by:
doStartNextScroll
in classScrollableHitSource
-
clearScroll
Description copied from class:ScrollableHitSource
Called to clear a scroll id.- Specified by:
clearScroll
in classScrollableHitSource
- Parameters:
scrollId
- the id to clearonCompletion
- implementers must call this after completing the clear whether they are successful or not
-
cleanup
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 classScrollableHitSource
- Parameters:
onCompletion
- implementers must call this after completing the cleanup whether they are successful or not
-