public class SnapshotInProgressAllocationDecider extends AllocationDecider
AllocationDecider prevents shards that are currently been snapshotted to be moved to other nodes.
| Modifier and Type | Field and Description |
|---|---|
static String |
CLUSTER_ROUTING_ALLOCATION_SNAPSHOT_RELOCATION_ENABLED
Disables relocation of shards that are currently being snapshotted.
|
static String |
NAME
|
componentSettings, logger, settings| Constructor and Description |
|---|
SnapshotInProgressAllocationDecider()
Creates a new
SnapshotInProgressAllocationDecider instance
|
SnapshotInProgressAllocationDecider(Settings
Creates a new
SnapshotInProgressAllocationDecider instance from given settings
|
SnapshotInProgressAllocationDecider(Settings
|
| Modifier and Type | Method and Description |
|---|---|
Decision |
canAllocate(ShardRouting
Returns a
Decision whether the given shard routing can be allocated on the given node.
|
Decision |
canRebalance(ShardRouting
Returns a
Decision whether the given shard routing can be re-balanced to the given allocation.
|
canAllocate, canAllocate, canRebalance, canRemainnodeNamepublic static final StringNAME
public static final StringCLUSTER_ROUTING_ALLOCATION_SNAPSHOT_RELOCATION_ENABLED
public SnapshotInProgressAllocationDecider()
SnapshotInProgressAllocationDecider instance
public SnapshotInProgressAllocationDecider(Settingssettings)
SnapshotInProgressAllocationDecider instance from given settings
settings -
Settings to use
@Inject public SnapshotInProgressAllocationDecider(Settingssettings, NodeSettingsService nodeSettingsService)
public DecisioncanRebalance(ShardRouting shardRouting, RoutingAllocation allocation)
Decision whether the given shard routing can be re-balanced to the given allocation. The default is
Decision.ALWAYS .
public DecisioncanAllocate(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation)
Decision whether the given shard routing can be allocated on the given node. The default is
Decision.ALWAYS .