org.elasticsearch.action.admin.indices.segments
Class TransportIndicesSegmentsAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>
              org.elasticsearch.action.admin.indices.segments.TransportIndicesSegmentsAction

public class TransportIndicesSegmentsAction
extends TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

Nested Class Summary

static class

TransportIndicesSegmentsAction.IndexShardSegmentRequest

Field Summary

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

clusterService, threadPool, transportService

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

componentSettings, logger, settings

Constructor Summary

TransportIndicesSegmentsAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService)

Method Summary

protected ClusterBlockException	checkGlobalBlock(ClusterState state, IndicesSegmentsRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, IndicesSegmentsRequest countRequest, String[] concreteIndices)
protected String	executor()
protected boolean	ignoreNonActiveExceptions()
protected IndicesSegmentsRequest	newRequest()
protected IndicesSegmentResponse	newResponse(IndicesSegmentsRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected TransportIndicesSegmentsAction.IndexShardSegmentRequest	newShardRequest()
protected TransportIndicesSegmentsAction.IndexShardSegmentRequest	newShardRequest(ShardRouting shard, IndicesSegmentsRequest request)
protected ShardSegments	newShardResponse()
protected ShardSegments	shardOperation(TransportIndicesSegmentsAction.IndexShardSegmentRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, IndicesSegmentsRequest request, String[] concreteIndices) Segments goes across *all* active shards.
protected String	transportAction()

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

accumulateExceptions, doExecute, ignoreException

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

execute, execute

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

TransportIndicesSegmentsAction

@Inject
public TransportIndicesSegmentsAction(Settings settings,
                                             ThreadPool threadPool,
                                             ClusterService clusterService,
                                             TransportService transportService,
                                             IndicesService indicesService)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

newRequest

protected IndicesSegmentsRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

ignoreNonActiveExceptions

protected boolean ignoreNonActiveExceptions()

Overrides:

ignoreNonActiveExceptions in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

shards

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

Segments goes across *all* active shards.

Specified by:

shards in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 IndicesSegmentsRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  IndicesSegmentsRequest countRequest,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

newResponse

protected IndicesSegmentResponse newResponse(IndicesSegmentsRequest request,
                                             AtomicReferenceArray shardsResponses,
                                             ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

newShardRequest

protected TransportIndicesSegmentsAction.IndexShardSegmentRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

newShardRequest

protected TransportIndicesSegmentsAction.IndexShardSegmentRequest newShardRequest(ShardRouting shard,
                                                                                  IndicesSegmentsRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

newShardResponse

protected ShardSegments newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

shardOperation

protected ShardSegments shardOperation(TransportIndicesSegmentsAction.IndexShardSegmentRequest request)
                                throws ElasticSearchException

Specified by:

shardOperation in class TransportBroadcastOperationAction<IndicesSegmentsRequest,IndicesSegmentResponse,TransportIndicesSegmentsAction.IndexShardSegmentRequest,ShardSegments>

Throws:

ElasticSearchException