public class TransportValidateQueryAction extends TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
TransportBroadcastAction.AsyncBroadcastAction
clusterService, transportService
actionName, indexNameExpressionResolver, taskManager, threadPool
deprecationLogger, logger, settings
Constructor and Description |
---|
TransportValidateQueryAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
SearchService searchService,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
ValidateQueryRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
ValidateQueryRequest countRequest,
java.lang.String[] concreteIndices) |
protected void |
doExecute(Task task,
ValidateQueryRequest request,
ActionListener<ValidateQueryResponse> listener) |
protected ValidateQueryResponse |
newResponse(ValidateQueryRequest request,
java.util.concurrent.atomic.AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected ShardValidateQueryRequest |
newShardRequest(int numShards,
ShardRouting shard,
ValidateQueryRequest request) |
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse |
newShardResponse() |
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse |
shardOperation(ShardValidateQueryRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
ValidateQueryRequest request,
java.lang.String[] concreteIndices)
Determines the shards this operation will be executed on.
|
doExecute, shardOperation
execute, execute, execute, execute
logDeprecatedSetting, logRemovedSetting, nodeName
@Inject public TransportValidateQueryAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, SearchService searchService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
protected void doExecute(Task task, ValidateQueryRequest request, ActionListener<ValidateQueryResponse> listener)
doExecute
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected ShardValidateQueryRequest newShardRequest(int numShards, ShardRouting shard, ValidateQueryRequest request)
newShardRequest
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse newShardResponse()
newShardResponse
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected GroupShardsIterator shards(ClusterState clusterState, ValidateQueryRequest request, java.lang.String[] concreteIndices)
TransportBroadcastAction
shards
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, ValidateQueryRequest request)
checkGlobalBlock
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, ValidateQueryRequest countRequest, java.lang.String[] concreteIndices)
checkRequestBlock
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected ValidateQueryResponse newResponse(ValidateQueryRequest request, java.util.concurrent.atomic.AtomicReferenceArray shardsResponses, ClusterState clusterState)
newResponse
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse shardOperation(ShardValidateQueryRequest request) throws java.io.IOException
shardOperation
in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
java.io.IOException