Package org.infinispan.query.affinity

Class ShardAllocationManagerImpl

java.lang.Object

org.infinispan.query.affinity.ShardAllocationManagerImpl

All Implemented Interfaces:

ShardAllocatorManager

public final class ShardAllocationManagerImpl
extends Object
implements ShardAllocatorManager

Since:

9.0

See Also:

ShardAllocatorManager

Constructor Summary

Constructors

Constructor	Description
ShardAllocationManagerImpl()

Method Summary

Modifier and Type	Method	Description
Address	getOwner(String shardId)
String	getShardFromKey(Object key)
String	getShardFromSegment(int segment)
Set<String>	getShards()
Set<String>	getShardsForModification(Address address)
void	initialize(int numberOfShards, int numSegments)	Initializes the ShardAllocatorManager with the configured number of segments and shards.
void	inject(Cache<?,?> cache, DistributionManager distributionManager)
boolean	isOwnershipChanged(TopologyChangedEvent<?,?> tce, String indeName)
void	onTopologyChange(TopologyChangedEvent<?,?> tce)

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardAllocationManagerImpl

public ShardAllocationManagerImpl()

Method Detail

inject

public void inject(Cache<?,?> cache,
                   DistributionManager distributionManager)

getShardFromSegment

public String getShardFromSegment(int segment)

Specified by:

getShardFromSegment in interface ShardAllocatorManager

Returns:

the shard name for a certain segment.

getOwner

public Address getOwner(String shardId)

Specified by:

getOwner in interface ShardAllocatorManager

Returns:

Owner of an index shard.

getShardFromKey

public String getShardFromKey(Object key)

Specified by:

getShardFromKey in interface ShardAllocatorManager

initialize

public void initialize(int numberOfShards,
                       int numSegments)

Description copied from interface: ShardAllocatorManager

Initializes the ShardAllocatorManager with the configured number of segments and shards.

Specified by:

initialize in interface ShardAllocatorManager

getShards

public Set<String> getShards()

Specified by:

getShards in interface ShardAllocatorManager

Returns:

the list of all shards available.

getShardsForModification

public Set<String> getShardsForModification(Address address)

Specified by:

getShardsForModification in interface ShardAllocatorManager

Returns:

the list of shards used to do modifications to the index for a given address.

isOwnershipChanged

public boolean isOwnershipChanged(TopologyChangedEvent<?,?> tce,
                                  String indeName)

Specified by:

isOwnershipChanged in interface ShardAllocatorManager

Returns:

Owner of an index shard given a certain ConsistentHash.

onTopologyChange

public void onTopologyChange(TopologyChangedEvent<?,?> tce)