Package org.elasticsearch.cluster.routing.allocation

Class IndexMetaDataUpdater

java.lang.Object

org.elasticsearch.cluster.routing.RoutingChangesObserver.AbstractRoutingChangesObserver

org.elasticsearch.cluster.routing.allocation.IndexMetaDataUpdater

All Implemented Interfaces:

RoutingChangesObserver

public class IndexMetaDataUpdater
extends RoutingChangesObserver.AbstractRoutingChangesObserver

Observer that tracks changes made to RoutingNodes in order to update the primary terms and in-sync allocation ids in IndexMetaData once the allocation round has completed. Primary terms are updated on primary initialization or when an active primary fails. Allocation ids are added for shards that become active and removed for shards that stop being active.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.cluster.routing.RoutingChangesObserver

RoutingChangesObserver.AbstractRoutingChangesObserver, RoutingChangesObserver.DelegatingRoutingChangesObserver

Constructor Summary

Constructors

Constructor	Description
IndexMetaDataUpdater()

Method Summary

Modifier and Type	Method	Description
MetaData	applyChanges(MetaData oldMetaData, RoutingTable newRoutingTable)	Updates the current MetaData based on the changes of this RoutingChangesObserver.
void	relocationCompleted(ShardRouting removedRelocationSource)	Called on relocation source when relocation completes after relocation target is started.
static ClusterState	removeStaleIdsWithoutRoutings(ClusterState clusterState, java.util.List<StaleShard> staleShards, org.apache.logging.log4j.Logger logger)	Removes allocation ids from the in-sync set for shard copies for which there is no routing entries in the routing table.
void	shardFailed(ShardRouting failedShard, UnassignedInfo unassignedInfo)	Called when a shard is failed or cancelled.
void	shardInitialized(ShardRouting unassignedShard, ShardRouting initializedShard)	Called when unassigned shard is initialized.
void	shardStarted(ShardRouting initializingShard, ShardRouting startedShard)	Called when an initializing shard is started.

Methods inherited from class java.lang.Object

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

Methods inherited from class org.elasticsearch.cluster.routing.RoutingChangesObserver.AbstractRoutingChangesObserver

initializedReplicaReinitialized, relocationSourceRemoved, relocationStarted, replicaPromoted, startedPrimaryReinitialized, unassignedInfoUpdated

Constructor Detail

IndexMetaDataUpdater

public IndexMetaDataUpdater()

Method Detail

shardInitialized

public void shardInitialized(ShardRouting unassignedShard,
                             ShardRouting initializedShard)

Description copied from interface: RoutingChangesObserver

Called when unassigned shard is initialized. Does not include initializing relocation target shards.

Specified by:

shardInitialized in interface RoutingChangesObserver

Overrides:

shardInitialized in class RoutingChangesObserver.AbstractRoutingChangesObserver

shardStarted

public void shardStarted(ShardRouting initializingShard,
                         ShardRouting startedShard)

Description copied from interface: RoutingChangesObserver

Called when an initializing shard is started.

Specified by:

shardStarted in interface RoutingChangesObserver

Overrides:

shardStarted in class RoutingChangesObserver.AbstractRoutingChangesObserver

shardFailed

public void shardFailed(ShardRouting failedShard,
                        UnassignedInfo unassignedInfo)

Description copied from interface: RoutingChangesObserver

Called when a shard is failed or cancelled.

Specified by:

shardFailed in interface RoutingChangesObserver

Overrides:

shardFailed in class RoutingChangesObserver.AbstractRoutingChangesObserver

relocationCompleted

public void relocationCompleted(ShardRouting removedRelocationSource)

Description copied from interface: RoutingChangesObserver

Called on relocation source when relocation completes after relocation target is started.

Specified by:

relocationCompleted in interface RoutingChangesObserver

Overrides:

relocationCompleted in class RoutingChangesObserver.AbstractRoutingChangesObserver

applyChanges

public MetaData applyChanges(MetaData oldMetaData,
                             RoutingTable newRoutingTable)

Updates the current MetaData based on the changes of this RoutingChangesObserver. Specifically we update IndexMetaData.getInSyncAllocationIds() and IndexMetaData.primaryTerm(int) based on the changes made during this allocation.

Parameters:

oldMetaData - MetaData object from before the routing nodes was changed.

newRoutingTable - RoutingTable object after routing changes were applied.

Returns:

adapted MetaData, potentially the original one if no change was needed.

removeStaleIdsWithoutRoutings

public static ClusterState removeStaleIdsWithoutRoutings(ClusterState clusterState,
                                                         java.util.List<StaleShard> staleShards,
                                                         org.apache.logging.log4j.Logger logger)

Removes allocation ids from the in-sync set for shard copies for which there is no routing entries in the routing table. This method is called in AllocationService before any changes to the routing table are made.