org.elasticsearch.action.deletebyquery
Class TransportIndexDeleteByQueryAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.replication.TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
              org.elasticsearch.action.deletebyquery.TransportIndexDeleteByQueryAction

public class TransportIndexDeleteByQueryAction
extends TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

Field Summary

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

clusterService, shardAction

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

TransportIndexDeleteByQueryAction(Settings settings, ClusterService clusterService, TransportService transportService, ThreadPool threadPool, TransportShardDeleteByQueryAction shardDeleteByQueryAction)

Method Summary

protected boolean	accumulateExceptions()
protected ClusterBlockException	checkGlobalBlock(ClusterState state, IndexDeleteByQueryRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, IndexDeleteByQueryRequest request)
protected IndexDeleteByQueryRequest	newRequestInstance()
protected IndexDeleteByQueryResponse	newResponseInstance(IndexDeleteByQueryRequest request, AtomicReferenceArray shardsResponses)
protected ShardDeleteByQueryRequest	newShardRequestInstance(IndexDeleteByQueryRequest request, int shardId)
protected GroupShardsIterator	shards(IndexDeleteByQueryRequest request)
protected String	transportAction()

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

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

TransportIndexDeleteByQueryAction

@Inject
public TransportIndexDeleteByQueryAction(Settings settings,
                                                ClusterService clusterService,
                                                TransportService transportService,
                                                ThreadPool threadPool,
                                                TransportShardDeleteByQueryAction shardDeleteByQueryAction)

Method Detail

newRequestInstance

protected IndexDeleteByQueryRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

newResponseInstance

protected IndexDeleteByQueryResponse newResponseInstance(IndexDeleteByQueryRequest request,
                                                         AtomicReferenceArray shardsResponses)

Specified by:

newResponseInstance in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 IndexDeleteByQueryRequest request)

Specified by:

checkGlobalBlock in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  IndexDeleteByQueryRequest request)

Specified by:

checkRequestBlock in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

shards

protected GroupShardsIterator shards(IndexDeleteByQueryRequest request)

Specified by:

shards in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>

newShardRequestInstance

protected ShardDeleteByQueryRequest newShardRequestInstance(IndexDeleteByQueryRequest request,
                                                            int shardId)

Specified by:

newShardRequestInstance in class TransportIndexReplicationOperationAction<IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>