org.elasticsearch.gateway.local

Class LocalGatewayAllocator

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.gateway.local.LocalGatewayAllocator

All Implemented Interfaces:

GatewayAllocator

public class LocalGatewayAllocator
extends AbstractComponent
implements GatewayAllocator

Field Summary

Fields

Modifier and Type	Field and Description
static String	INDEX_RECOVERY_INITIAL_SHARDS

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
LocalGatewayAllocator(Settings settings, TransportNodesListGatewayStartedShards startedAction, TransportNodesListShardStoreMetaData storeAction)

Method Summary

Modifier and Type	Method and Description
boolean	allocateUnassigned(RoutingAllocation allocation)
void	applyFailedShards(FailedRerouteAllocation allocation)
void	applyStartedShards(StartedRerouteAllocation allocation) Apply all shards
int	getNumberOfInFlightFetch()
void	setReallocation(ClusterService clusterService, RoutingService routingService)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INDEX_RECOVERY_INITIAL_SHARDS

public static final String INDEX_RECOVERY_INITIAL_SHARDS

See Also:

Constant Field Values

Constructor Detail

LocalGatewayAllocator

@Inject
public LocalGatewayAllocator(Settings settings,
                                     TransportNodesListGatewayStartedShards startedAction,
                                     TransportNodesListShardStoreMetaData storeAction)

Method Detail

setReallocation

public void setReallocation(ClusterService clusterService,
                            RoutingService routingService)

getNumberOfInFlightFetch

public int getNumberOfInFlightFetch()

applyStartedShards

public void applyStartedShards(StartedRerouteAllocation allocation)

Description copied from interface: GatewayAllocator

Apply all shards

Specified by:

applyStartedShards in interface GatewayAllocator

applyFailedShards

public void applyFailedShards(FailedRerouteAllocation allocation)

Specified by:

applyFailedShards in interface GatewayAllocator

allocateUnassigned

public boolean allocateUnassigned(RoutingAllocation allocation)

Specified by:

allocateUnassigned in interface GatewayAllocator