Package org.elasticsearch.action.update

Class TransportUpdateAction

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.single.instance.TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

org.elasticsearch.action.update.TransportUpdateAction

public class TransportUpdateAction
extends TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

Field Summary

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

deprecationLogger, logger, settings

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

actionName, indexNameExpressionResolver, taskManager, threadPool

Fields inherited from class org.elasticsearch.action.support.single.instance.TransportInstanceSingleOperationAction

clusterService, transportService

Constructor Summary

Constructors

Constructor	Description
TransportUpdateAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, TransportBulkAction bulkAction, TransportCreateIndexAction createIndexAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, IndicesService indicesService, AutoCreateIndex autoCreateIndex)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(UpdateRequest request, ActionListener<UpdateResponse> listener)
protected java.lang.String	executor()
protected UpdateResponse	newResponse()
static void	resolveAndValidateRouting(MetaData metaData, java.lang.String concreteIndex, UpdateRequest request)
protected void	resolveRequest(ClusterState state, UpdateRequest request)	Resolves the request.
protected boolean	retryOnFailure(java.lang.Exception e)
protected void	shardOperation(UpdateRequest request, ActionListener<UpdateResponse> listener)
protected void	shardOperation(UpdateRequest request, ActionListener<UpdateResponse> listener, int retryCount)
protected ShardIterator	shards(ClusterState clusterState, UpdateRequest request)	Should return an iterator with a single shard!

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

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

doExecute, execute, execute, execute, execute

Methods inherited from class org.elasticsearch.action.support.single.instance.TransportInstanceSingleOperationAction

checkGlobalBlock, checkRequestBlock, transportOptions

Constructor Detail

TransportUpdateAction

@Inject
public TransportUpdateAction(Settings settings,
                             ThreadPool threadPool,
                             ClusterService clusterService,
                             TransportService transportService,
                             TransportBulkAction bulkAction,
                             TransportCreateIndexAction createIndexAction,
                             UpdateHelper updateHelper,
                             ActionFilters actionFilters,
                             IndexNameExpressionResolver indexNameExpressionResolver,
                             IndicesService indicesService,
                             AutoCreateIndex autoCreateIndex)

Method Detail

executor

protected java.lang.String executor()

Specified by:

executor in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

newResponse

protected UpdateResponse newResponse()

Specified by:

newResponse in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

retryOnFailure

protected boolean retryOnFailure(java.lang.Exception e)

Overrides:

retryOnFailure in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

resolveRequest

protected void resolveRequest(ClusterState state,
                              UpdateRequest request)

Description copied from class: TransportInstanceSingleOperationAction

Resolves the request. Throws an exception if the request cannot be resolved.

Specified by:

resolveRequest in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

resolveAndValidateRouting

public static void resolveAndValidateRouting(MetaData metaData,
                                             java.lang.String concreteIndex,
                                             UpdateRequest request)

doExecute

protected void doExecute(UpdateRequest request,
                         ActionListener<UpdateResponse> listener)

Overrides:

doExecute in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

shards

protected ShardIterator shards(ClusterState clusterState,
                               UpdateRequest request)

Description copied from class: TransportInstanceSingleOperationAction

Should return an iterator with a single shard!

Specified by:

shards in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

shardOperation

protected void shardOperation(UpdateRequest request,
                              ActionListener<UpdateResponse> listener)

Specified by:

shardOperation in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

shardOperation

protected void shardOperation(UpdateRequest request,
                              ActionListener<UpdateResponse> listener,
                              int retryCount)