org.elasticsearch.action.admin.indices.validate.query

Class TransportValidateQueryAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<Request,Response>

org.elasticsearch.action.support.broadcast.TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

org.elasticsearch.action.admin.indices.validate.query.TransportValidateQueryAction

public class TransportValidateQueryAction
extends TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastAction

TransportBroadcastAction.AsyncBroadcastAction

Field Summary

Fields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastAction

clusterService, transportService

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

actionName, indexNameExpressionResolver, taskManager, threadPool

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportValidateQueryAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, SearchService searchService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

Method Summary

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.

Methods inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastAction

doExecute, shardOperation

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

execute, execute, execute, execute

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportValidateQueryAction

@Inject
public TransportValidateQueryAction(Settings settings,
                                            ThreadPool threadPool,
                                            ClusterService clusterService,
                                            TransportService transportService,
                                            SearchService searchService,
                                            ActionFilters actionFilters,
                                            IndexNameExpressionResolver indexNameExpressionResolver)

Method Detail

doExecute

protected void doExecute(Task task,
                         ValidateQueryRequest request,
                         ActionListener<ValidateQueryResponse> listener)

Overrides:

doExecute in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

newShardRequest

protected ShardValidateQueryRequest newShardRequest(int numShards,
                                                    ShardRouting shard,
                                                    ValidateQueryRequest request)

Specified by:

newShardRequest in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

newShardResponse

protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

shards

protected GroupShardsIterator shards(ClusterState clusterState,
                                     ValidateQueryRequest request,
                                     java.lang.String[] concreteIndices)

Description copied from class: TransportBroadcastAction

Determines the shards this operation will be executed on. The operation is executed once per shard iterator, typically on the first shard in it. If the operation fails, it will be retried on the next shard in the iterator.

Specified by:

shards in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 ValidateQueryRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  ValidateQueryRequest countRequest,
                                                  java.lang.String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

newResponse

protected ValidateQueryResponse newResponse(ValidateQueryRequest request,
                                            java.util.concurrent.atomic.AtomicReferenceArray shardsResponses,
                                            ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

shardOperation

protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse shardOperation(ShardValidateQueryRequest request)
                                                                                                   throws java.io.IOException

Specified by:

shardOperation in class TransportBroadcastAction<ValidateQueryRequest,ValidateQueryResponse,ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

Throws:

java.io.IOException