public class TransportDeleteByQueryAction extends TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
clusterService, indexAction
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportDeleteByQueryAction(Settings settings,
ClusterService clusterService,
TransportService transportService,
ThreadPool threadPool,
TransportIndexDeleteByQueryAction indexDeleteByQueryAction,
NodeSettingsService nodeSettingsService,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
accumulateExceptions() |
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
DeleteByQueryRequest replicationPingRequest) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
DeleteByQueryRequest request,
String[] concreteIndices) |
protected void |
doExecute(DeleteByQueryRequest request,
ActionListener<DeleteByQueryResponse> listener) |
protected org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest |
newIndexRequestInstance(DeleteByQueryRequest request,
String index,
Set<String> routing,
long startTimeInMillis) |
protected DeleteByQueryRequest |
newRequestInstance() |
protected DeleteByQueryResponse |
newResponseInstance(DeleteByQueryRequest request,
AtomicReferenceArray indexResponses) |
protected Map<String,Set<String>> |
resolveRouting(ClusterState clusterState,
DeleteByQueryRequest request) |
execute, execute, forceThreadedListener
nodeName
@Inject public TransportDeleteByQueryAction(Settings settings, ClusterService clusterService, TransportService transportService, ThreadPool threadPool, TransportIndexDeleteByQueryAction indexDeleteByQueryAction, NodeSettingsService nodeSettingsService, ActionFilters actionFilters)
protected void doExecute(DeleteByQueryRequest request, ActionListener<DeleteByQueryResponse> listener)
doExecute
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected Map<String,Set<String>> resolveRouting(ClusterState clusterState, DeleteByQueryRequest request) throws ElasticsearchException
resolveRouting
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
ElasticsearchException
protected DeleteByQueryRequest newRequestInstance()
newRequestInstance
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected DeleteByQueryResponse newResponseInstance(DeleteByQueryRequest request, AtomicReferenceArray indexResponses)
newResponseInstance
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected boolean accumulateExceptions()
accumulateExceptions
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, DeleteByQueryRequest replicationPingRequest)
checkGlobalBlock
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, DeleteByQueryRequest request, String[] concreteIndices)
checkRequestBlock
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
protected org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest newIndexRequestInstance(DeleteByQueryRequest request, String index, Set<String> routing, long startTimeInMillis)
newIndexRequestInstance
in class TransportIndicesReplicationOperationAction<DeleteByQueryRequest,DeleteByQueryResponse,org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest,IndexDeleteByQueryResponse,ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
Copyright © 2009–2015. All rights reserved.