Package org.elasticsearch.action.admin.indices.diskusage

Class TransportAnalyzeIndexDiskUsageAction

java.lang.Object

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

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

org.elasticsearch.action.support.broadcast.TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

org.elasticsearch.action.admin.indices.diskusage.TransportAnalyzeIndexDiskUsageAction

public class TransportAnalyzeIndexDiskUsageAction
extends TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

Nested Class Summary

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

TransportBroadcastAction.AsyncBroadcastAction

Field Summary

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

clusterService, indexNameExpressionResolver, transportService

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportAnalyzeIndexDiskUsageAction(ClusterService clusterService, TransportService transportService, IndicesService indexServices, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

Method Summary

Modifier and Type	Method	Description
protected ClusterBlockException	checkGlobalBlock(ClusterState state, AnalyzeIndexDiskUsageRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, AnalyzeIndexDiskUsageRequest request, String[] concreteIndices)
protected void	doExecute(Task task, AnalyzeIndexDiskUsageRequest request, ActionListener<AnalyzeIndexDiskUsageResponse> listener)
protected AnalyzeIndexDiskUsageResponse	newResponse(AnalyzeIndexDiskUsageRequest request, AtomicReferenceArray<?> shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest	newShardRequest(int numShards, ShardRouting shard, AnalyzeIndexDiskUsageRequest request)
protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse	readShardResponse(StreamInput in)
protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse	shardOperation(org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest request, Task task)
protected GroupShardsIterator<ShardIterator>	shards(ClusterState clusterState, AnalyzeIndexDiskUsageRequest request, String[] concreteIndices)	Determines the shards this operation will be executed on.

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

TransportAnalyzeIndexDiskUsageAction

@Inject
public TransportAnalyzeIndexDiskUsageAction(ClusterService clusterService,
 TransportService transportService,
 IndicesService indexServices,
 ActionFilters actionFilters,
 IndexNameExpressionResolver indexNameExpressionResolver)

Method Details

doExecute

protected void doExecute(Task task,
 AnalyzeIndexDiskUsageRequest request,
 ActionListener<AnalyzeIndexDiskUsageResponse> listener)

Overrides:

doExecute in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest newShardRequest(int numShards,
 ShardRouting shard,
 AnalyzeIndexDiskUsageRequest request)

Specified by:

newShardRequest in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

readShardResponse

protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse readShardResponse(StreamInput in)
                                                                                                    throws IOException

Specified by:

readShardResponse in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

Throws:

IOException

shardOperation

protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse shardOperation(org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest request,
 Task task)
                                                                                                 throws IOException

Specified by:

shardOperation in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

Throws:

IOException

newResponse

protected AnalyzeIndexDiskUsageResponse newResponse(AnalyzeIndexDiskUsageRequest request,
 AtomicReferenceArray<?> shardsResponses,
 ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

shards

protected GroupShardsIterator<ShardIterator> shards(ClusterState clusterState,
 AnalyzeIndexDiskUsageRequest request,
 String[] concreteIndices)

Description copied from class: TransportBroadcastAction

Determines the shards this operation will be executed on. The operation is executed once per shard iterator, typically on the first shard in it. If the operation fails, it will be retried on the next shard in the iterator.

Specified by:

shards in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
 AnalyzeIndexDiskUsageRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>

checkRequestBlock

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

Specified by:

checkRequestBlock in class TransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest,org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>