Package | Description |
---|---|
org.elasticsearch.cluster.routing | |
org.elasticsearch.cluster.routing.allocation.allocator |
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. |
MutableShardRouting[] |
RoutingNodes.UnassignedShards.drain() |
MutableShardRouting |
RoutingNode.get(int i) |
MutableShardRouting |
RoutingNodes.RoutingNodeIterator.next() |
Modifier and Type | Method and Description |
---|---|
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.
|
Collection<MutableShardRouting> |
RoutingNode.copyShards() |
List<MutableShardRouting> |
RoutingNodes.ignoredUnassigned() |
Iterator<MutableShardRouting> |
RoutingNodes.UnassignedShards.iterator() |
Iterator<MutableShardRouting> |
RoutingNodes.RoutingNodesIterator.iterator() |
Iterator<MutableShardRouting> |
RoutingNodes.RoutingNodeIterator.iterator() |
Iterator<MutableShardRouting> |
RoutingNode.iterator() |
List<MutableShardRouting> |
RoutingNodes.shards(com.google.common.base.Predicate<MutableShardRouting> predicate) |
List<MutableShardRouting> |
RoutingNodes.shardsWithState(ShardRoutingState... state) |
List<MutableShardRouting> |
RoutingNode.shardsWithState(ShardRoutingState... states)
Determine the shards with a specific state
|
List<MutableShardRouting> |
RoutingNodes.shardsWithState(String index,
ShardRoutingState... state) |
List<MutableShardRouting> |
RoutingNode.shardsWithState(String index,
ShardRoutingState... states)
Determine the shards of an index with a specific state
|
Modifier and Type | Method and Description |
---|---|
void |
RoutingNodes.UnassignedShards.add(MutableShardRouting mutableShardRouting) |
void |
RoutingNodes.assign(MutableShardRouting shard,
String nodeId)
Assign a shard to a node.
|
void |
RoutingNodes.cancelRelocation(MutableShardRouting shard)
Cancels a relocation of a shard that shard must relocating.
|
void |
RoutingNodes.reinitShadowPrimary(MutableShardRouting candidate) |
void |
RoutingNodes.relocate(MutableShardRouting shard,
String nodeId)
Relocate a shard to another node.
|
void |
RoutingNodes.started(MutableShardRouting shard)
Mark a shard as started and adjusts internal statistics.
|
void |
RoutingNodes.swapPrimaryFlag(MutableShardRouting... shards)
swaps the status of a shard, making replicas primary and vice versa.
|
Modifier and Type | Method and Description |
---|---|
void |
RoutingNodes.UnassignedShards.addAll(Collection<MutableShardRouting> mutableShardRoutings) |
List<MutableShardRouting> |
RoutingNodes.shards(com.google.common.base.Predicate<MutableShardRouting> predicate) |
Constructor and Description |
---|
RoutingNode(String nodeId,
DiscoveryNode node,
List<MutableShardRouting> shards) |
Modifier and Type | Method and Description |
---|---|
boolean |
BalancedShardsAllocator.Balancer.move(MutableShardRouting shard,
RoutingNode node)
This function executes a move operation moving the given shard from
the given node to the minimal eligible node with respect to the
weight function.
|
boolean |
ShardsAllocators.move(MutableShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
boolean |
ShardsAllocator.move(MutableShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation)
Moves a shard from the given node to other node.
|
boolean |
EvenShardsCountAllocator.move(MutableShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
boolean |
BalancedShardsAllocator.move(MutableShardRouting shardRouting,
RoutingNode node,
RoutingAllocation allocation) |
Copyright © 2009–2015. All rights reserved.