Module org.elasticsearch.server

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, 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)
protected void	resolveRequest(ClusterState state, UpdateRequest docWriteRequest)	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

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 docWriteRequest)

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>

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)
                       throws IOException

Throws:

IOException