| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
CacheImpl.keyPartitioner |
| Modifier and Type | Method and Description |
|---|---|
static int |
SegmentSpecificCommand.extractSegment(ReplicableCommand command,
Object key,
KeyPartitioner keyPartitioner)
Utility to extract the segment from a given command that may be a
SegmentSpecificCommand. |
| Modifier and Type | Field and Description |
|---|---|
static AttributeDefinition<KeyPartitioner> |
HashConfiguration.KEY_PARTITIONER |
| Modifier and Type | Method and Description |
|---|---|
KeyPartitioner |
HashConfiguration.keyPartitioner() |
| Modifier and Type | Method and Description |
|---|---|
HashConfigurationBuilder |
HashConfigurationBuilder.keyPartitioner(KeyPartitioner keyPartitioner)
Key partitioner, controlling the mapping of keys to hash segments.
|
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
AbstractInternalDataContainer.keyPartitioner |
| Modifier and Type | Method and Description |
|---|---|
static LocalizedCacheTopology |
LocalizedCacheTopology.makeSegmentedSingletonTopology(KeyPartitioner keyPartitioner,
int numSegments,
Address localAddress)
Creates a new local topology that has a single address but multiple segments.
|
| Constructor and Description |
|---|
LocalizedCacheTopology(CacheMode cacheMode,
CacheTopology cacheTopology,
KeyPartitioner keyPartitioner,
Address localAddress,
boolean connected) |
| Modifier and Type | Method and Description |
|---|---|
default boolean |
KeyPartitioner.matches(KeyPartitioner other) |
| Modifier and Type | Class and Description |
|---|---|
class |
AffinityPartitioner
Key partitioner that maps keys to segments using information contained in
AffinityTaggedKey. |
class |
HashFunctionPartitioner
Key partitioner that computes a key's segment based on a hash function.
|
class |
SingleSegmentKeyPartitioner
KeyPartitioner that always returns 0 for a given segment.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GroupingPartitioner
Key partitioner that uses
Group annotations to map
grouped keys to the same segment. |
| Modifier and Type | Method and Description |
|---|---|
KeyPartitioner |
GroupingPartitioner.unwrap() |
| Constructor and Description |
|---|
GroupingPartitioner(KeyPartitioner partitioner,
GroupManager groupManager) |
| Modifier and Type | Method and Description |
|---|---|
static LocalizedCacheTopology |
DistributionManagerImpl.makeSingletonTopology(CacheMode cacheMode,
KeyPartitioner keyPartitioner,
int numSegments,
Address localAddress) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
ExpirationManagerImpl.keyPartitioner |
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
BaseDistributionInterceptor.keyPartitioner |
protected KeyPartitioner |
L1NonTxInterceptor.keyPartitioner |
protected KeyPartitioner |
ScatteredDistributionInterceptor.keyPartitioner |
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
PrefetchInterceptor.keyPartitioner |
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
ClusteringDependentLogic.AbstractClusteringDependentLogic.keyPartitioner |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusteringDependentLogic.LocalLogic.init(Transport transport,
Configuration configuration,
KeyPartitioner keyPartitioner) |
| Modifier and Type | Method and Description |
|---|---|
KeyPartitioner |
InitializationContextImpl.getKeyPartitioner() |
| Constructor and Description |
|---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
KeyPartitioner keyPartitioner,
PersistenceMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshallableEntryFactory marshallableEntryFactory,
Executor nonBlockingExecutor,
GlobalConfiguration globalConfiguration,
BlockingManager blockingManager) |
| Modifier and Type | Method and Description |
|---|---|
static <K> Predicate<? super K> |
PersistenceUtil.combinePredicate(IntSet segments,
KeyPartitioner keyPartitioner,
Predicate<? super K> filter) |
| Modifier and Type | Method and Description |
|---|---|
KeyPartitioner |
InitializationContext.getKeyPartitioner()
The configured partitioner that can be used to determine which segment a given key belongs to.
|
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
StateConsumerImpl.keyPartitioner |
protected KeyPartitioner |
StateProviderImpl.keyPartitioner |
| Constructor and Description |
|---|
OutboundTransferTask(Address destination,
IntSet segments,
int segmentCount,
int chunkSize,
int topologyId,
KeyPartitioner keyPartitioner,
Consumer<Collection<StateChunk>> onChunkReplicated,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName,
boolean applyState,
boolean pushTransfer) |
| Modifier and Type | Field and Description |
|---|---|
protected KeyPartitioner |
AbstractCacheStream.keyPartitioner |
| Modifier and Type | Method and Description |
|---|---|
static CompletionStage<Map<Object,IncrementableEntryVersion>> |
WriteSkewHelper.performWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
EntryLoader<?,?> entryLoader,
VersionGenerator versionGenerator,
TxInvocationContext<?> context,
WriteSkewHelper.KeySpecificLogic ksl,
KeyPartitioner keyPartitioner) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.