public class TransportUpdateAction extends TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
deprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
clusterService, transportService
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) |
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!
|
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doExecute, execute, execute, execute, execute
checkGlobalBlock, checkRequestBlock, transportOptions
@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)
protected java.lang.String executor()
executor
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected UpdateResponse newResponse()
newResponse
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected boolean retryOnFailure(java.lang.Exception e)
retryOnFailure
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected void resolveRequest(ClusterState state, UpdateRequest request)
TransportInstanceSingleOperationAction
resolveRequest
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
public static void resolveAndValidateRouting(MetaData metaData, java.lang.String concreteIndex, UpdateRequest request)
protected void doExecute(UpdateRequest request, ActionListener<UpdateResponse> listener)
doExecute
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected ShardIterator shards(ClusterState clusterState, UpdateRequest request)
TransportInstanceSingleOperationAction
shards
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected void shardOperation(UpdateRequest request, ActionListener<UpdateResponse> listener)
shardOperation
in class TransportInstanceSingleOperationAction<UpdateRequest,UpdateResponse>
protected void shardOperation(UpdateRequest request, ActionListener<UpdateResponse> listener, int retryCount)