org.elasticsearch.action.deletebyquery
Class TransportDeleteByQueryAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.replication.TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
              org.elasticsearch.action.deletebyquery.TransportDeleteByQueryAction

public class TransportDeleteByQueryAction
extends TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

Field Summary

Fields inherited from class org.elasticsearch.action.support.replication.TransportIndicesReplicationOperationAction

clusterService, indexAction

Fields inherited from class org.elasticsearch.action.support.TransportAction

threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

TransportDeleteByQueryAction(Settings settings, ClusterService clusterService, TransportService transportService, ThreadPool threadPool, TransportIndexDeleteByQueryAction indexDeleteByQueryAction)

Method Summary

protected boolean	accumulateExceptions()
protected ClusterBlockException	checkGlobalBlock(ClusterState state, DeleteByQueryRequest replicationPingRequest)
protected ClusterBlockException	checkRequestBlock(ClusterState state, DeleteByQueryRequest replicationPingRequest, String[] concreteIndices)
protected IndexDeleteByQueryRequest	newIndexRequestInstance(DeleteByQueryRequest request, String index, Set<String> routing)
protected DeleteByQueryRequest	newRequestInstance()
protected DeleteByQueryResponse	newResponseInstance(DeleteByQueryRequest request, AtomicReferenceArray indexResponses)
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.replication.TransportIndicesReplicationOperationAction

doExecute

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportDeleteByQueryAction

@Inject
public TransportDeleteByQueryAction(Settings settings,
                                           ClusterService clusterService,
                                           TransportService transportService,
                                           ThreadPool threadPool,
                                           TransportIndexDeleteByQueryAction indexDeleteByQueryAction)

Method Detail

newRequestInstance

protected DeleteByQueryRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

newResponseInstance

protected DeleteByQueryResponse newResponseInstance(DeleteByQueryRequest request,
                                                    AtomicReferenceArray indexResponses)

Specified by:

newResponseInstance in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 DeleteByQueryRequest replicationPingRequest)

Specified by:

checkGlobalBlock in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  DeleteByQueryRequest replicationPingRequest,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

newIndexRequestInstance

protected IndexDeleteByQueryRequest newIndexRequestInstance(DeleteByQueryRequest request,
                                                            String index,
                                                            Set<String> routing)

Specified by:

newIndexRequestInstance in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>