Package org.elasticsearch.action.update

Class TransportUpdateAction

java.lang.Object

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.action.support.single.instance.TransportInstanceSingleOperationAction

indexNameExpressionResolver, threadPool, transportService

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportUpdateAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, UpdateHelper updateHelper, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, IndicesService indicesService, AutoCreateIndex autoCreateIndex, NodeClient client)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task task, UpdateRequest request, ActionListener<UpdateResponse> listener)
protected String	executor(ShardId shardId)
protected UpdateResponse	newResponse(StreamInput in)
static void	resolveAndValidateRouting(Metadata metadata, String concreteIndex, UpdateRequest request)
protected void	resolveRequest(ClusterState state, UpdateRequest request)	Resolves the request.
protected boolean	retryOnFailure(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.action.support.single.instance.TransportInstanceSingleOperationAction

checkGlobalBlock, checkRequestBlock, transportOptions

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

execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportUpdateAction

@Inject
public TransportUpdateAction(ThreadPool threadPool,
 ClusterService clusterService,
 TransportService transportService,
 UpdateHelper updateHelper,
 ActionFilters actionFilters,
 IndexNameExpressionResolver indexNameExpressionResolver,
 IndicesService indicesService,
 AutoCreateIndex autoCreateIndex,
 NodeClient client)

Method Details

executor

protected String executor(ShardId shardId)

Specified by:

executor in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

newResponse

protected UpdateResponse newResponse(StreamInput in)
                              throws IOException

Specified by:

newResponse in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

Throws:

IOException

retryOnFailure

protected boolean retryOnFailure(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,
 String concreteIndex,
 UpdateRequest request)

doExecute

protected void doExecute(Task task,
 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)