Package org.elasticsearch.index.reindex

Class AsyncDeleteByQueryAction

java.lang.Object

org.elasticsearch.index.reindex.AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>

org.elasticsearch.index.reindex.AsyncDeleteByQueryAction

public class AsyncDeleteByQueryAction
extends AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>

Implementation of delete-by-query using scrolling and bulk.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.index.reindex.AbstractAsyncBulkByScrollAction

AbstractAsyncBulkByScrollAction.DeleteRequestWrapper, AbstractAsyncBulkByScrollAction.IndexRequestWrapper, AbstractAsyncBulkByScrollAction.OpType, AbstractAsyncBulkByScrollAction.RequestWrapper<Self extends org.elasticsearch.action.DocWriteRequest<Self>>, AbstractAsyncBulkByScrollAction.ScriptApplier

Field Summary

Fields inherited from class org.elasticsearch.index.reindex.AbstractAsyncBulkByScrollAction

clusterState, logger, mainRequest, scriptService, task, threadPool, worker

Constructor Summary

Constructors

Constructor

Description

AsyncDeleteByQueryAction(org.elasticsearch.index.reindex.BulkByScrollTask task, org.apache.logging.log4j.Logger logger, org.elasticsearch.client.ParentTaskAssigningClient client, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.index.reindex.DeleteByQueryRequest request, org.elasticsearch.script.ScriptService scriptService, org.elasticsearch.cluster.ClusterState clusterState, org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)

Method Summary

Modifier and Type	Method	Description
protected boolean	accept(org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)	Used to accept or ignore a search hit.
protected AbstractAsyncBulkByScrollAction.RequestWrapper<org.elasticsearch.action.delete.DeleteRequest>	buildRequest(org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)	Build the AbstractAsyncBulkByScrollAction.RequestWrapper for a single search hit.
protected AbstractAsyncBulkByScrollAction.RequestWrapper<?>	copyMetadata(AbstractAsyncBulkByScrollAction.RequestWrapper<?> request, org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)	Overrides the parent's implementation is much more Update/Reindex oriented and so also copies things like timestamp/ttl which we don't care for a deletion.
protected boolean	needsSourceDocumentVersions()	Does this operation need the versions of the source documents?

Methods inherited from class org.elasticsearch.index.reindex.AbstractAsyncBulkByScrollAction

buildResponse, buildScriptApplier, buildScrollableResultSource, copyRouting, finishHim, finishHim, start, wrap, wrap

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncDeleteByQueryAction

public AsyncDeleteByQueryAction(org.elasticsearch.index.reindex.BulkByScrollTask task,
                                org.apache.logging.log4j.Logger logger,
                                org.elasticsearch.client.ParentTaskAssigningClient client,
                                org.elasticsearch.threadpool.ThreadPool threadPool,
                                org.elasticsearch.index.reindex.DeleteByQueryRequest request,
                                org.elasticsearch.script.ScriptService scriptService,
                                org.elasticsearch.cluster.ClusterState clusterState,
                                org.elasticsearch.action.ActionListener<org.elasticsearch.index.reindex.BulkByScrollResponse> listener)

Method Detail

needsSourceDocumentVersions

protected boolean needsSourceDocumentVersions()

Description copied from class: AbstractAsyncBulkByScrollAction

Does this operation need the versions of the source documents?

Specified by:

needsSourceDocumentVersions in class AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>

accept

protected boolean accept(org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)

Description copied from class: AbstractAsyncBulkByScrollAction

Used to accept or ignore a search hit. Ignored search hits will be excluded from the bulk request. It is also where we fail on invalid search hits, like when the document has no source but it's required.

Overrides:

accept in class AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>

buildRequest

protected AbstractAsyncBulkByScrollAction.RequestWrapper<org.elasticsearch.action.delete.DeleteRequest> buildRequest(org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)

Description copied from class: AbstractAsyncBulkByScrollAction

Build the AbstractAsyncBulkByScrollAction.RequestWrapper for a single search hit. This shouldn't handle metadata or scripting. That will be handled by copyMetadata and apply functions that can be overridden.

Specified by:

buildRequest in class AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>

copyMetadata

protected AbstractAsyncBulkByScrollAction.RequestWrapper<?> copyMetadata(AbstractAsyncBulkByScrollAction.RequestWrapper<?> request,
                                                                         org.elasticsearch.index.reindex.ScrollableHitSource.Hit doc)

Overrides the parent's implementation is much more Update/Reindex oriented and so also copies things like timestamp/ttl which we don't care for a deletion.

Overrides:

copyMetadata in class AbstractAsyncBulkByScrollAction<org.elasticsearch.index.reindex.DeleteByQueryRequest>