Package org.elasticsearch.index.reindex
Class ClientScrollableHitSource
- java.lang.Object
-
- org.elasticsearch.index.reindex.ScrollableHitSource
-
- org.elasticsearch.index.reindex.ClientScrollableHitSource
-
public class ClientScrollableHitSource extends ScrollableHitSource
A scrollable source of hits from a Client instance.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
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
Constructors Constructor Description 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 Summary
Modifier and Type Method Description protected void
cleanup(java.lang.Runnable onCompletion)
Called after the process has been totally finished to clean up any resources the process needed like remote connections.void
clearScroll(java.lang.String scrollId, java.lang.Runnable onCompletion)
Called to clear a scroll id.void
doStart(java.util.function.Consumer<? super ScrollableHitSource.Response> onResponse)
protected void
doStartNextScroll(java.lang.String scrollId, TimeValue extraKeepAlive, java.util.function.Consumer<? super ScrollableHitSource.Response> onResponse)
-
Methods inherited from class org.elasticsearch.index.reindex.ScrollableHitSource
close, setScroll, start, startNextScroll
-
-
-
-
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
-
doStart
public void doStart(java.util.function.Consumer<? super ScrollableHitSource.Response> onResponse)
- Specified by:
doStart
in classScrollableHitSource
-
doStartNextScroll
protected void doStartNextScroll(java.lang.String scrollId, TimeValue extraKeepAlive, java.util.function.Consumer<? super ScrollableHitSource.Response> onResponse)
- Specified by:
doStartNextScroll
in classScrollableHitSource
-
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 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(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 classScrollableHitSource
- Parameters:
onCompletion
- implementers must call this after completing the cleanup whether they are successful or not
-
-