public class GatewayAllocator extends AbstractComponent
deprecationLogger, logger, settings
Constructor and Description |
---|
GatewayAllocator(Settings settings,
TransportNodesListGatewayStartedShards startedAction,
TransportNodesListShardStoreMetaData storeAction) |
Modifier and Type | Method and Description |
---|---|
void |
allocateUnassigned(RoutingAllocation allocation) |
void |
applyFailedShards(RoutingAllocation allocation,
java.util.List<FailedShard> failedShards) |
void |
applyStartedShards(RoutingAllocation allocation,
java.util.List<ShardRouting> startedShards) |
AllocateUnassignedDecision |
decideUnassignedShardAllocation(ShardRouting unassignedShard,
RoutingAllocation routingAllocation)
Computes and returns the design for allocating a single unassigned shard.
|
int |
getNumberOfInFlightFetch() |
protected static void |
innerAllocatedUnassigned(RoutingAllocation allocation,
PrimaryShardAllocator primaryShardAllocator,
ReplicaShardAllocator replicaShardAllocator) |
void |
setReallocation(ClusterService clusterService,
RoutingService routingService) |
logDeprecatedSetting, logRemovedSetting, nodeName
@Inject public GatewayAllocator(Settings settings, TransportNodesListGatewayStartedShards startedAction, TransportNodesListShardStoreMetaData storeAction)
public void setReallocation(ClusterService clusterService, RoutingService routingService)
public int getNumberOfInFlightFetch()
public void applyStartedShards(RoutingAllocation allocation, java.util.List<ShardRouting> startedShards)
public void applyFailedShards(RoutingAllocation allocation, java.util.List<FailedShard> failedShards)
public void allocateUnassigned(RoutingAllocation allocation)
protected static void innerAllocatedUnassigned(RoutingAllocation allocation, PrimaryShardAllocator primaryShardAllocator, ReplicaShardAllocator replicaShardAllocator)
public AllocateUnassignedDecision decideUnassignedShardAllocation(ShardRouting unassignedShard, RoutingAllocation routingAllocation)
AllocateUnassignedDecision.NOT_TAKEN
is returned.