public class TransportIndexDeleteByQueryAction extends TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
clusterService, shardAction
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportIndexDeleteByQueryAction(Settings settings,
ClusterService clusterService,
ThreadPool threadPool,
TransportShardDeleteByQueryAction shardDeleteByQueryAction,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
accumulateExceptions() |
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
protected IndexDeleteByQueryResponse |
newResponseInstance(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request,
List<ShardDeleteByQueryResponse> shardDeleteByQueryResponses,
int failuresCount,
List<ShardOperationFailedException> shardFailures) |
protected ShardDeleteByQueryRequest |
newShardRequestInstance(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request,
int shardId) |
protected GroupShardsIterator |
shards(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
doExecute
execute, execute, forceThreadedListener
nodeName
@Inject public TransportIndexDeleteByQueryAction(Settings settings, ClusterService clusterService, ThreadPool threadPool, TransportShardDeleteByQueryAction shardDeleteByQueryAction, ActionFilters actionFilters)
protected IndexDeleteByQueryResponse newResponseInstance(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request, List<ShardDeleteByQueryResponse> shardDeleteByQueryResponses, int failuresCount, List<ShardOperationFailedException> shardFailures)
newResponseInstance
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected boolean accumulateExceptions()
accumulateExceptions
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request)
checkGlobalBlock
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request)
checkRequestBlock
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected GroupShardsIterator shards(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request)
shards
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected ShardDeleteByQueryRequest newShardRequestInstance(org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request, int shardId)
newShardRequestInstance
in class TransportIndexReplicationOperationAction<org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
Copyright © 2009–2015. All rights reserved.