Modifier and Type | Class and Description |
---|---|
class |
FailedRerouteAllocation
This
RoutingAllocation keeps a shard which routing
allocation has faild |
class |
StartedRerouteAllocation
This
RoutingAllocation holds a list of started shards within a
cluster |
Modifier and Type | Method and Description |
---|---|
boolean |
GatewayAllocator.allocateUnassigned(RoutingAllocation allocation) |
boolean |
ShardsAllocators.allocateUnassigned(RoutingAllocation allocation) |
boolean |
ShardsAllocator.allocateUnassigned(RoutingAllocation allocation)
Assign all unassigned shards to nodes
|
boolean |
EvenShardsCountAllocator.allocateUnassigned(RoutingAllocation allocation) |
boolean |
BalancedShardsAllocator.allocateUnassigned(RoutingAllocation allocation) |
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) |
boolean |
ShardsAllocators.rebalance(RoutingAllocation allocation) |
boolean |
ShardsAllocator.rebalance(RoutingAllocation allocation)
Rebalancing number of shards on all nodes
|
boolean |
EvenShardsCountAllocator.rebalance(RoutingAllocation allocation) |
boolean |
BalancedShardsAllocator.rebalance(RoutingAllocation allocation) |
Constructor and Description |
---|
Balancer(ESLogger logger,
RoutingAllocation allocation,
BalancedShardsAllocator.WeightFunction weight,
float threshold) |
Modifier and Type | Method and Description |
---|---|
RerouteExplanation |
AllocateAllocationCommand.execute(RoutingAllocation allocation,
boolean explain) |
RerouteExplanation |
CancelAllocationCommand.execute(RoutingAllocation allocation,
boolean explain) |
RoutingExplanations |
AllocationCommands.execute(RoutingAllocation allocation,
boolean explain)
Executes all wrapped commands on a given
RoutingAllocation |
RerouteExplanation |
MoveAllocationCommand.execute(RoutingAllocation allocation,
boolean explain) |
RerouteExplanation |
AllocationCommand.execute(RoutingAllocation allocation,
boolean explain)
Executes the command on a
RoutingAllocation setup |
Modifier and Type | Method and Description |
---|---|
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 |
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 | Method and Description |
---|---|
boolean |
LocalGatewayAllocator.allocateUnassigned(RoutingAllocation allocation) |
Modifier and Type | Method and Description |
---|---|
boolean |
NoneGatewayAllocator.allocateUnassigned(RoutingAllocation allocation) |
Copyright © 2009–2015. All rights reserved.