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

org.elasticsearch.action.update.TransportUpdateAction

public class TransportUpdateAction
extends TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.single.instance.TransportInstanceSingleOperationAction

TransportInstanceSingleOperationAction.InternalRequest

Field Summary

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

clusterService, transportService

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

actionName, threadPool

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportUpdateAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, TransportIndexAction indexAction, TransportDeleteAction deleteAction, TransportCreateIndexAction createIndexAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndicesService indicesService)

Method Summary

Modifier and Type	Method and Description
protected void	doExecute(UpdateRequest request, ActionListener<UpdateResponse> listener)
protected String	executor()
protected UpdateRequest	newRequest()
protected UpdateResponse	newResponse()
protected boolean	resolveRequest(ClusterState state, TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener) Resolves the request.
protected boolean	retryOnFailure(Throwable e)
protected void	shardOperation(TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener)
protected void	shardOperation(TransportInstanceSingleOperationAction.InternalRequest request, ActionListener<UpdateResponse> listener, int retryCount)
protected ShardIterator	shards(ClusterState clusterState, TransportInstanceSingleOperationAction.InternalRequest 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, forceThreadedListener

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

TransportUpdateAction

@Inject
public TransportUpdateAction(Settings settings,
                                     ThreadPool threadPool,
                                     ClusterService clusterService,
                                     TransportService transportService,
                                     TransportIndexAction indexAction,
                                     TransportDeleteAction deleteAction,
                                     TransportCreateIndexAction createIndexAction,
                                     UpdateHelper updateHelper,
                                     ActionFilters actionFilters,
                                     IndicesService indicesService)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

newRequest

protected UpdateRequest newRequest()

Specified by:

newRequest in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

newResponse

protected UpdateResponse newResponse()

Specified by:

newResponse in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

retryOnFailure

protected boolean retryOnFailure(Throwable e)

Overrides:

retryOnFailure in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

resolveRequest

protected boolean resolveRequest(ClusterState state,
                                 TransportInstanceSingleOperationAction.InternalRequest request,
                                 ActionListener<UpdateResponse> listener)

Description copied from class: TransportInstanceSingleOperationAction

Resolves the request. If the resolve means a different execution, then return false here to indicate not to continue and execute this request.

Specified by:

resolveRequest in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

doExecute

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

Overrides:

doExecute in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

shards

protected ShardIterator shards(ClusterState clusterState,
                               TransportInstanceSingleOperationAction.InternalRequest request)
                        throws ElasticsearchException

Description copied from class: TransportInstanceSingleOperationAction

Should return an iterator with a single shard!

Specified by:

shards in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

Throws:

ElasticsearchException

shardOperation

protected void shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
                              ActionListener<UpdateResponse> listener)
                       throws ElasticsearchException

Specified by:

shardOperation in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>

Throws:

ElasticsearchException

shardOperation

protected void shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
                              ActionListener<UpdateResponse> listener,
                              int retryCount)
                       throws ElasticsearchException

Throws:

ElasticsearchException