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.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

Constructors

Constructor	Description
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 Summary

Modifier and Type	Method	Description
protected void	cleanup(Runnable onCompletion)	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, 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.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

public void doStart(RejectAwareActionListener<ScrollableHitSource.Response> searchListener)

Specified by:

doStart in class ScrollableHitSource

doStartNextScroll

protected void doStartNextScroll(String scrollId,
 org.elasticsearch.core.TimeValue extraKeepAlive,
 RejectAwareActionListener<ScrollableHitSource.Response> searchListener)

Specified by:

doStartNextScroll in class ScrollableHitSource

clearScroll

public void clearScroll(String scrollId,
 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(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