Module org.elasticsearch.server
Class TransportAnalyzeIndexDiskUsageAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse>
org.elasticsearch.action.support.HandledTransportAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse>
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
FieldsFields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastAction
clusterService, indexNameExpressionResolver, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportAnalyzeIndexDiskUsageAction(ClusterService clusterService, TransportService transportService, IndicesService indexServices, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver) -
Method Summary
Modifier and TypeMethodDescriptionprotected ClusterBlockExceptioncheckGlobalBlock(ClusterState state, AnalyzeIndexDiskUsageRequest request) protected ClusterBlockExceptioncheckRequestBlock(ClusterState state, AnalyzeIndexDiskUsageRequest request, String[] concreteIndices) protected voiddoExecute(Task task, AnalyzeIndexDiskUsageRequest request, ActionListener<AnalyzeIndexDiskUsageResponse> listener) protected AnalyzeIndexDiskUsageResponsenewResponse(AnalyzeIndexDiskUsageRequest request, AtomicReferenceArray<?> shardsResponses, ClusterState clusterState) protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequestnewShardRequest(int numShards, ShardRouting shard, AnalyzeIndexDiskUsageRequest request) protected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponseprotected org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponseshardOperation(org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest request, Task task) protected List<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.broadcast.TransportBroadcastAction
doExecuteForkedMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
TYPE
-
-
Constructor Details
-
TransportAnalyzeIndexDiskUsageAction
@Inject public TransportAnalyzeIndexDiskUsageAction(ClusterService clusterService, TransportService transportService, IndicesService indexServices, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver)
-
-
Method Details
-
doExecute
protected void doExecute(Task task, AnalyzeIndexDiskUsageRequest request, ActionListener<AnalyzeIndexDiskUsageResponse> listener) - Overrides:
doExecutein classTransportBroadcastAction<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:
newShardRequestin classTransportBroadcastAction<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:
readShardResponsein classTransportBroadcastAction<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:
shardOperationin classTransportBroadcastAction<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:
newResponsein classTransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse, org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest, org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>
-
shards
protected List<ShardIterator> shards(ClusterState clusterState, AnalyzeIndexDiskUsageRequest request, String[] concreteIndices) Description copied from class:TransportBroadcastActionDetermines 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:
shardsin classTransportBroadcastAction<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:
checkGlobalBlockin classTransportBroadcastAction<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:
checkRequestBlockin classTransportBroadcastAction<AnalyzeIndexDiskUsageRequest,AnalyzeIndexDiskUsageResponse, org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardRequest, org.elasticsearch.action.admin.indices.diskusage.AnalyzeDiskUsageShardResponse>
-