org.elasticsearch.action.admin.indices.upgrade.post

Class TransportUpgradeAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

org.elasticsearch.action.admin.indices.upgrade.post.TransportUpgradeAction

public class TransportUpgradeAction
extends TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

Upgrade index/indices action.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

TransportBroadcastOperationAction.AsyncBroadcastAction

Field Summary

Fields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

clusterService, threadPool, transportService

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

actionName

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportUpgradeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, TransportUpgradeSettingsAction upgradeSettingsAction)

Method Summary

Modifier and Type	Method and Description
protected ClusterBlockException	checkGlobalBlock(ClusterState state, UpgradeRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, UpgradeRequest request, String[] concreteIndices)
protected void	doExecute(UpgradeRequest request, ActionListener<UpgradeResponse> listener)
protected String	executor()
protected UpgradeRequest	newRequest()
protected UpgradeResponse	newResponse(UpgradeRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest	newShardRequest()
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest	newShardRequest(int numShards, ShardRouting shard, UpgradeRequest request)
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse	newShardResponse()
protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse	shardOperation(org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, UpgradeRequest request, String[] concreteIndices) The upgrade request works against *all* shards.

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

TransportUpgradeAction

@Inject
public TransportUpgradeAction(Settings settings,
                                      ThreadPool threadPool,
                                      ClusterService clusterService,
                                      TransportService transportService,
                                      IndicesService indicesService,
                                      ActionFilters actionFilters,
                                      TransportUpgradeSettingsAction upgradeSettingsAction)

Method Detail

newResponse

protected UpgradeResponse newResponse(UpgradeRequest request,
                                      AtomicReferenceArray shardsResponses,
                                      ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest newShardRequest(int numShards,
                                                                                                  ShardRouting shard,
                                                                                                  UpgradeRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

newShardResponse

protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

shardOperation

protected org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse shardOperation(org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest request)

Specified by:

shardOperation in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

shards

protected GroupShardsIterator shards(ClusterState clusterState,
                                     UpgradeRequest request,
                                     String[] concreteIndices)

The upgrade request works against *all* shards.

Specified by:

shards in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 UpgradeRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  UpgradeRequest request,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

doExecute

protected void doExecute(UpgradeRequest request,
                         ActionListener<UpgradeResponse> listener)

Overrides:

doExecute in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>

newRequest

protected UpgradeRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<UpgradeRequest,UpgradeResponse,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeRequest,org.elasticsearch.action.admin.indices.upgrade.post.ShardUpgradeResponse>