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.broadcast.TransportBroadcastOperationAction<ValidateQueryRequest,ValidateQueryResponse,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>
              org.elasticsearch.action.admin.indices.validate.query.TransportValidateQueryAction

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

Field Summary

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

clusterService, threadPool, transportService

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

componentSettings, logger, settings

Constructor Summary

TransportValidateQueryAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ScriptService scriptService)

Method Summary

protected ClusterBlockException	checkGlobalBlock(ClusterState state, ValidateQueryRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, ValidateQueryRequest countRequest, String[] concreteIndices)
protected String	executor()
protected ValidateQueryRequest	newRequest()
protected ValidateQueryResponse	newResponse(ValidateQueryRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest	newShardRequest()
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest	newShardRequest(ShardRouting shard, ValidateQueryRequest request)
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse	newShardResponse()
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse	shardOperation(org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, ValidateQueryRequest request, String[] concreteIndices)
protected String	transportAction()

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

accumulateExceptions, doExecute, ignoreException, ignoreNonActiveExceptions

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

TransportValidateQueryAction

@Inject
public TransportValidateQueryAction(Settings settings,
                                           ThreadPool threadPool,
                                           ClusterService clusterService,
                                           TransportService transportService,
                                           IndicesService indicesService,
                                           ScriptService scriptService)

Method Detail

executor

protected String executor()

Specified by:

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

transportAction

protected String transportAction()

Specified by:

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

newRequest

protected ValidateQueryRequest newRequest()

Specified by:

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

newShardRequest

protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest newShardRequest()

Specified by:

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

newShardRequest

protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest newShardRequest(ShardRouting shard,
                                                                                                          ValidateQueryRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<ValidateQueryRequest,ValidateQueryResponse,org.elasticsearch.action.admin.indices.validate.query.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 TransportBroadcastOperationAction<ValidateQueryRequest,ValidateQueryResponse,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest,org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryResponse>

shards

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

Specified by:

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

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 ValidateQueryRequest request)

Specified by:

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

checkRequestBlock

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

Specified by:

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

newResponse

protected ValidateQueryResponse newResponse(ValidateQueryRequest request,
                                            AtomicReferenceArray shardsResponses,
                                            ClusterState clusterState)

Specified by:

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

shardOperation

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

Specified by:

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

Throws:

ElasticSearchException