Modifier and Type | Method and Description |
---|---|
ShardRouting[] |
ClusterSearchShardsGroup.getShards() |
Constructor and Description |
---|
ClusterSearchShardsGroup(String index,
int shardId,
ShardRouting[] shards) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest |
TransportClearIndicesCacheAction.newShardRequest(int numShards,
ShardRouting shard,
ClearIndicesCacheRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.flush.ShardFlushRequest |
TransportFlushAction.newShardRequest(int numShards,
ShardRouting shard,
FlushRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.optimize.ShardOptimizeRequest |
TransportOptimizeAction.newShardRequest(int numShards,
ShardRouting shard,
OptimizeRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.recovery.TransportRecoveryAction.ShardRecoveryRequest |
TransportRecoveryAction.newShardRequest(int numShards,
ShardRouting shard,
RecoveryRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.refresh.ShardRefreshRequest |
TransportRefreshAction.newShardRequest(int numShards,
ShardRouting shard,
RefreshRequest request) |
Modifier and Type | Method and Description |
---|---|
ShardRouting |
ShardSegments.getShardRouting() |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.segments.TransportIndicesSegmentsAction.IndexShardSegmentRequest |
TransportIndicesSegmentsAction.newShardRequest(int numShards,
ShardRouting shard,
IndicesSegmentsRequest request) |
Modifier and Type | Method and Description |
---|---|
ShardRouting |
ShardStats.getShardRouting()
The shard routing information (cluster wide shard state).
|
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.ImmutableMap<ShardRouting,CommonStats> |
IndicesStatsResponse.asMap() |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.stats.TransportIndicesStatsAction.IndexShardStatsRequest |
TransportIndicesStatsAction.newShardRequest(int numShards,
ShardRouting shard,
IndicesStatsRequest request) |
Constructor and Description |
---|
ShardStats(IndexShard indexShard,
ShardRouting shardRouting,
CommonStatsFlags flags) |
Modifier and Type | Method and Description |
---|---|
ShardRouting |
ShardStatus.getShardRouting()
Deprecated.
The shard routing information (cluster wide shard state).
|
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.status.TransportIndicesStatusAction.IndexShardStatusRequest |
TransportIndicesStatusAction.newShardRequest(int numShards,
ShardRouting shard,
IndicesStatusRequest request)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.admin.indices.validate.query.ShardValidateQueryRequest |
TransportValidateQueryAction.newShardRequest(int numShards,
ShardRouting shard,
ValidateQueryRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.count.ShardCountRequest |
TransportCountAction.newShardRequest(int numShards,
ShardRouting shard,
CountRequest request) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.exists.ShardExistsRequest |
TransportExistsAction.newShardRequest(int numShards,
ShardRouting shard,
ExistsRequest request) |
Modifier and Type | Method and Description |
---|---|
protected PercolateShardRequest |
TransportPercolateAction.newShardRequest(int numShards,
ShardRouting shard,
PercolateRequest request) |
Modifier and Type | Method and Description |
---|---|
static ShardSearchTransportRequest |
TransportSearchHelper.internalSearchRequest(ShardRouting shardRouting,
int numberOfShards,
SearchRequest request,
String[] filteringAliases,
long nowInMillis,
boolean useSlowScroll) |
protected void |
TransportSearchTypeAction.BaseAsyncAction.processFirstPhaseResult(int shardIndex,
ShardRouting shard,
FirstResult result) |
Modifier and Type | Method and Description |
---|---|
protected org.elasticsearch.action.suggest.ShardSuggestRequest |
TransportSuggestAction.newShardRequest(int numShards,
ShardRouting shard,
SuggestRequest request) |
Modifier and Type | Method and Description |
---|---|
protected abstract ShardRequest |
TransportBroadcastOperationAction.newShardRequest(int numShards,
ShardRouting shard,
Request request) |
protected void |
TransportBroadcastOperationAction.AsyncBroadcastAction.onOperation(ShardRouting shard,
int shardIndex,
ShardResponse response) |
protected void |
TransportBroadcastOperationAction.AsyncBroadcastAction.performOperation(ShardIterator shardIt,
ShardRouting shard,
int shardIndex) |
Modifier and Type | Method and Description |
---|---|
static String |
InternalClusterInfoService.shardIdentifierFromRouting(ShardRouting shardRouting)
Method that incorporates the ShardId for the shard into a string that
includes a 'p' or 'r' depending on whether the shard is a primary.
|
Modifier and Type | Method and Description |
---|---|
void |
ShardStateAction.resendShardFailed(ShardRouting shardRouting,
String indexUUID,
String reason,
DiscoveryNode masterNode) |
void |
ShardStateAction.shardFailed(ShardRouting shardRouting,
String indexUUID,
String reason) |
void |
ShardStateAction.shardStarted(ShardRouting shardRouting,
String indexUUID,
String reason) |
void |
ShardStateAction.shardStarted(ShardRouting shardRouting,
String indexUUID,
String reason,
DiscoveryNode masterNode) |
Modifier and Type | Class and Description |
---|---|
class |
ImmutableShardRouting
ImmutableShardRouting immutably encapsulates information about shard
routings like id, state, version, etc. |
class |
MutableShardRouting
Similar to
ImmutableShardRouting this class keeps metadata of the current shard. |
Modifier and Type | Method and Description |
---|---|
ShardRouting |
PlainShardsIterator.nextOrNull() |
ShardRouting |
ShardsIterator.nextOrNull()
Returns the next shard, or null if none available.
|
ShardRouting |
IndexShardRoutingTable.primaryShard() |
ShardRouting |
IllegalShardRoutingStateException.shard()
Returns the shard instance referenced by this exception
|
ShardRouting |
ShardRouting.targetRoutingIfRelocating()
If the shard is relocating, return a shard routing representing the target shard or null o.w.
|
ShardRouting |
ImmutableShardRouting.targetRoutingIfRelocating() |
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.activeShards()
Returns a
ImmutableList of active shards |
List<ShardRouting> |
RoutingTable.allShards(String... indices)
All the shards (replicas) for the provided indices.
|
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.assignedShards()
Returns a
ImmutableList of assigned shards |
Iterable<ShardRouting> |
PlainShardsIterator.asUnordered() |
Iterable<ShardRouting> |
ShardsIterator.asUnordered() |
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.getActiveShards()
Returns a
ImmutableList of active shards |
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.getAssignedShards()
Returns a
ImmutableList of assigned shards |
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.getShards()
Returns a
ImmutableList of shards |
com.google.common.collect.UnmodifiableIterator<ShardRouting> |
IndexShardRoutingTable.iterator() |
List<ShardRouting> |
IndexShardRoutingTable.replicaShards() |
List<ShardRouting> |
IndexShardRoutingTable.replicaShardsWithState(ShardRoutingState... states) |
com.google.common.collect.ImmutableList<ShardRouting> |
IndexShardRoutingTable.shards()
Returns a
ImmutableList of shards |
List<ShardRouting> |
IndexShardRoutingTable.shardsWithState(ShardRoutingState state) |
List<ShardRouting> |
IndexRoutingTable.shardsWithState(ShardRoutingState state)
|
List<ShardRouting> |
RoutingTable.shardsWithState(ShardRoutingState state) |
List<ShardRouting> |
ShardShuffler.shuffle(List<ShardRouting> shards)
Equivalent to calling
shuffle(shards, nextSeed()) . |
abstract List<ShardRouting> |
ShardShuffler.shuffle(List<ShardRouting> shards,
int seed)
Return a shuffled view over the list of shards.
|
List<ShardRouting> |
RotationShardShuffler.shuffle(List<ShardRouting> shards,
int seed) |
Modifier and Type | Method and Description |
---|---|
MutableShardRouting |
RoutingNodes.activePrimary(ShardRouting shard)
Returns the active primary shard for the given ShardRouting or
null if
no primary is found or the primary is not active. |
MutableShardRouting |
RoutingNodes.activeReplica(ShardRouting shard)
Returns one active replica shard for the given ShardRouting shard ID or
null if
no active replica is found. |
IndexRoutingTable.Builder |
IndexRoutingTable.Builder.addShard(IndexShardRoutingTable refData,
ShardRouting shard)
Adds a new shard routing (makes a copy of it), with reference data used from the index shard routing table
if it needs to be created.
|
boolean |
RoutingNodes.allReplicasActive(ShardRouting shardRouting)
Returns
true iff all replicas are active for the given shard routing. |
Iterable<MutableShardRouting> |
RoutingNodes.assignedShards(ShardRouting shard)
Returns all shards that are not in the state UNASSIGNED with the same shard
ID as the given shard.
|
IndexShardRoutingTable.Builder |
IndexShardRoutingTable.Builder.removeShard(ShardRouting shardEntry) |
Modifier and Type | Method and Description |
---|---|
List<ShardRouting> |
ShardShuffler.shuffle(List<ShardRouting> shards)
Equivalent to calling
shuffle(shards, nextSeed()) . |
abstract List<ShardRouting> |
ShardShuffler.shuffle(List<ShardRouting> shards,
int seed)
Return a shuffled view over the list of shards.
|
List<ShardRouting> |
RotationShardShuffler.shuffle(List<ShardRouting> shards,
int seed) |
Constructor and Description |
---|
IllegalShardRoutingStateException(ShardRouting shard,
String message) |
IllegalShardRoutingStateException(ShardRouting shard,
String message,
Throwable cause) |
ImmutableShardRouting(ShardRouting copy) |
ImmutableShardRouting(ShardRouting copy,
long version) |
MutableShardRouting(ShardRouting copy) |
MutableShardRouting(ShardRouting copy,
long version) |
Constructor and Description |
---|
PlainShardIterator(ShardId shardId,
List<ShardRouting> shards)
Creates a
PlainShardIterator instance that iterates over a subset of the given shards
this the a given shardId . |
PlainShardsIterator(List<ShardRouting> shards) |
Modifier and Type | Method and Description |
---|---|
List<ShardRouting> |
FailedRerouteAllocation.failedShards() |
List<? extends ShardRouting> |
StartedRerouteAllocation.startedShards()
Get started shards
|
Modifier and Type | Method and Description |
---|---|
RoutingAllocation.Result |
AllocationService.applyFailedShard(ClusterState clusterState,
ShardRouting failedShard) |
Modifier and Type | Method and Description |
---|---|
RoutingAllocation.Result |
AllocationService.applyFailedShards(ClusterState clusterState,
List<ShardRouting> failedShards)
Applies the failed shards.
|
RoutingAllocation.Result |
AllocationService.applyStartedShards(ClusterState clusterState,
List<? extends ShardRouting> startedShards)
Applies the started shards.
|
RoutingAllocation.Result |
AllocationService.applyStartedShards(ClusterState clusterState,
List<? extends ShardRouting> startedShards,
boolean withReroute) |
Constructor and Description |
---|
FailedRerouteAllocation(AllocationDeciders deciders,
RoutingNodes routingNodes,
DiscoveryNodes nodes,
List<ShardRouting> failedShards,
ClusterInfo clusterInfo) |
StartedRerouteAllocation(AllocationDeciders deciders,
RoutingNodes routingNodes,
DiscoveryNodes nodes,
List<? extends ShardRouting> startedShards,
ClusterInfo clusterInfo) |
Modifier and Type | Method and Description |
---|---|
Decision |
ReplicaAfterPrimaryActiveAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
AllocationDeciders.canAllocate(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
AllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be allocated at all at this state of the
RoutingAllocation . |
Decision |
ThrottlingAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
ReplicaAfterPrimaryActiveAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
SnapshotInProgressAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be
allocated on the given node. |
Decision |
FilterAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
EnableAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
AwarenessAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
NodeVersionAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
AllocationDeciders.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
SameShardAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
DisableAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation)
Deprecated.
|
Decision |
AllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be
allocated on the given node. |
Decision |
DiskThresholdDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
ShardsLimitAllocationDecider.canAllocate(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
SnapshotInProgressAllocationDecider.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be
re-balanced to the given allocation. |
Decision |
ClusterRebalanceAllocationDecider.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
AllocationDeciders.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
RebalanceOnlyWhenActiveAllocationDecider.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
AllocationDecider.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be
re-balanced to the given allocation. |
Decision |
ConcurrentRebalanceAllocationDecider.canRebalance(ShardRouting shardRouting,
RoutingAllocation allocation) |
Decision |
FilterAllocationDecider.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
AwarenessAllocationDecider.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
AllocationDeciders.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
AllocationDecider.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation)
Returns a
Decision whether the given shard routing can be remain
on the given node. |
Decision |
DiskThresholdDecider.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Decision |
ShardsLimitAllocationDecider.canRemain(ShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Modifier and Type | Field and Description |
---|---|
protected ShardRouting |
IndexShard.shardRouting |
Modifier and Type | Method and Description |
---|---|
ShardRouting |
IndexShard.routingEntry()
Returns the latest cluster routing entry received with this shard.
|
Modifier and Type | Method and Description |
---|---|
IndexShard |
ShadowIndexShard.routingEntry(ShardRouting newRouting)
In addition to the regular accounting done in
IndexShard.routingEntry(org.elasticsearch.cluster.routing.ShardRouting) ,
if this shadow replica needs to be promoted to a primary, the shard is
failed in order to allow a new primary to be re-allocated. |
IndexShard |
IndexShard.routingEntry(ShardRouting newRouting) |
Modifier and Type | Method and Description |
---|---|
void |
InternalIndicesLifecycle.shardRoutingChanged(IndexShard indexShard,
ShardRouting oldRouting,
ShardRouting newRouting) |
void |
IndicesLifecycle.Listener.shardRoutingChanged(IndexShard indexShard,
ShardRouting oldRouting,
ShardRouting newRouting)
Called when the shard routing has changed state.
|
Constructor and Description |
---|
ShardSearchTransportRequest(SearchRequest searchRequest,
ShardRouting shardRouting,
int numberOfShards,
boolean useSlowScroll,
String[] filteringAliases,
long nowInMillis) |
Copyright © 2009–2015. All rights reserved.