Package org.elasticsearch.index.reindex
Class ClientScrollableHitSource
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, countSearchRetry, <ScrollableHitSource.AsyncResponse> onResponse, <> fail, ParentTaskAssigningClient client, SearchRequest firstSearchRequest)
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
onCompletion)
Called after the process has been totally finished to clean up any resources the process needed like remote connections.void
scrollId, onCompletion)
Called to clear a scroll id.void
doStart(RejectAwareActionListener<ScrollableHitSource.Response> searchListener)
protected void
scrollId, org.elasticsearch.core.TimeValue extraKeepAlive, RejectAwareActionListener<ScrollableHitSource.Response> searchListener)
Methods inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
close, setScroll, start
Methods inherited from class java.lang.
, , , , , , , , , ,
-
Constructor Details
-
ClientScrollableHitSource
public ClientScrollableHitSource(org.apache.logging.log4j.Logger logger, BackoffPolicy backoffPolicy, ThreadPool threadPool, countSearchRetry, <ScrollableHitSource.AsyncResponse> onResponse, <> fail, ParentTaskAssigningClient client, SearchRequest firstSearchRequest)
-
-
Method Details
-
doStart
- Specified by:
doStart
in classScrollableHitSource
-
doStartNextScroll
protected void doStartNextScroll( scrollId, org.elasticsearch.core.TimeValue extraKeepAlive, RejectAwareActionListener<ScrollableHitSource.Response> searchListener)- Specified by:
doStartNextScroll
in classScrollableHitSource
-
clearScroll
public void clearScroll( scrollId, onCompletion)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
protected void cleanup( 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 classScrollableHitSource
- Parameters:
onCompletion
- implementers must call this after completing the cleanup whether they are successful or not
-