Package | Description |
---|---|
org.elasticsearch.cluster.routing | |
org.elasticsearch.cluster.routing.allocation.allocator | |
org.elasticsearch.cluster.routing.allocation.decider |
Modifier and Type | Method and Description |
---|---|
RoutingNode |
RoutingNodes.RoutingNodesIterator.next() |
RoutingNode |
RoutingNodes.node(String nodeId) |
RoutingNode[] |
RoutingNodes.toArray() |
Modifier and Type | Method and Description |
---|---|
Iterator<RoutingNode> |
RoutingNodes.iterator() |
Constructor and Description |
---|
RoutingNodeIterator(RoutingNode iterable) |
Constructor and Description |
---|
RoutingNodesIterator(Iterator<RoutingNode> iterator) |
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) |
Modifier and Type | Method and Description |
---|---|
DiskUsage |
DiskThresholdDecider.averageUsage(RoutingNode node,
Map<String,DiskUsage> usages)
Returns a
DiskUsage for the RoutingNode using the
average usage of other nodes in the disk usage map. |
Decision |
ThrottlingAllocationDecider.canAllocate(RoutingNode node,
RoutingAllocation allocation) |
Decision |
AllocationDeciders.canAllocate(RoutingNode node,
RoutingAllocation allocation) |
Decision |
AllocationDecider.canAllocate(RoutingNode node,
RoutingAllocation allocation)
Returns a
Decision whether the given node can allow any allocation 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 |
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) |
long |
DiskThresholdDecider.sizeOfRelocatingShards(RoutingNode node,
Map<String,Long> shardSizes,
boolean subtractShardsMovingAway)
Returns the size of all shards that are currently being relocated to
the node, but may not be finished transfering yet.
|
Copyright © 2009–2015. All rights reserved.