Modifier and Type | Method and Description |
---|---|
ConsistentHash |
ReadOnlyManyCommand.getConsistentHash() |
Modifier and Type | Method and Description |
---|---|
void |
ReadOnlyManyCommand.setConsistentHash(ConsistentHash ch) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
GetAllCommand.getConsistentHash() |
Modifier and Type | Method and Description |
---|---|
void |
GetAllCommand.setConsistentHash(ConsistentHash ch) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
HashConfiguration.consistentHash()
Deprecated.
Since 5.2, replaced by
HashConfiguration.consistentHashFactory() . |
Modifier and Type | Method and Description |
---|---|
HashConfigurationBuilder |
HashConfigurationBuilder.consistentHash(ConsistentHash consistentHash)
Deprecated.
Since 5.2, replaced by
HashConfigurationBuilder.consistentHashFactory(ConsistentHashFactory) . |
Modifier and Type | Method and Description |
---|---|
HashConfigurationBuilder |
HashConfigurationBuilder.consistentHashFactory(ConsistentHashFactory<? extends ConsistentHash> consistentHashFactory)
The consistent hash factory in use.
|
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DistributionManager.getConsistentHash()
Retrieves the consistent hash instance currently in use, an instance of the configured ConsistentHash
class (which defaults to
DefaultConsistentHash . |
ConsistentHash |
DistributionManager.getReadConsistentHash() |
ConsistentHash |
DistributionManager.getWriteConsistentHash() |
Modifier and Type | Interface and Description |
---|---|
interface |
ConsistentHashFactory<CH extends ConsistentHash>
Factory for
ConsistentHash instances. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultConsistentHash
Default
ConsistentHash implementation. |
class |
ReplicatedConsistentHash
Special implementation of
ConsistentHash for replicated caches. |
Constructor and Description |
---|
OwnershipStatistics(ConsistentHash ch,
List<Address> activeNodes) |
Modifier and Type | Class and Description |
---|---|
class |
PartitionerConsistentHash
|
Constructor and Description |
---|
PartitionerConsistentHash(ConsistentHash ch,
KeyPartitioner keyPartitioner) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DistributionManagerImpl.getConsistentHash() |
ConsistentHash |
DistributionManagerImpl.getReadConsistentHash() |
ConsistentHash |
DistributionManagerImpl.getWriteConsistentHash() |
Modifier and Type | Field and Description |
---|---|
protected ConsistentHash |
ReadOnlySegmentAwareIterator.ch |
protected ConsistentHash |
ReadOnlySegmentAwareSet.ch |
protected ConsistentHash |
ReadOnlySegmentAwareMap.ch |
Constructor and Description |
---|
ReadOnlySegmentAwareEntryIterator(Iterator<Map.Entry<K,V>> iter,
ConsistentHash ch,
Set<Integer> allowedSegments) |
ReadOnlySegmentAwareEntrySet(Set<Map.Entry<K,V>> set,
ConsistentHash ch,
Set<Integer> allowedSegments) |
ReadOnlySegmentAwareIterator(Iterator<E> iter,
ConsistentHash ch,
Set<Integer> allowedSegments) |
ReadOnlySegmentAwareMap(Map<K,V> map,
ConsistentHash ch,
Set<Integer> allowedSegments) |
ReadOnlySegmentAwareSet(Set<E> set,
ConsistentHash ch,
Set<Integer> allowedSegments) |
Modifier and Type | Method and Description |
---|---|
protected InternalCacheEntry |
BaseDistributionInterceptor.fetchValueLocallyIfAvailable(ConsistentHash consistentHash,
Object key)
Deprecated.
|
protected boolean |
BaseDistributionInterceptor.isValueAvailableLocally(ConsistentHash consistentHash,
Object key)
Deprecated.
|
Constructor and Description |
---|
DistributedItr(int batchSize,
UUID identifier,
EntryRetriever.SegmentListener segmentListener,
ConsistentHash hash) |
Modifier and Type | Method and Description |
---|---|
void |
CacheNotifierImpl.notifyDataRehashed(ConsistentHash readCH,
ConsistentHash writeCH,
ConsistentHash unionCH,
int newTopologyId,
boolean pre) |
void |
CacheNotifier.notifyDataRehashed(ConsistentHash oldCH,
ConsistentHash newCH,
ConsistentHash unionCH,
int newTopologyId,
boolean pre) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
DataRehashedEvent.getConsistentHashAtEnd() |
ConsistentHash |
TopologyChangedEvent.getConsistentHashAtEnd() |
ConsistentHash |
DataRehashedEvent.getConsistentHashAtStart() |
ConsistentHash |
TopologyChangedEvent.getConsistentHashAtStart() |
ConsistentHash |
DataRehashedEvent.getUnionConsistentHash() |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
EventImpl.getConsistentHashAtEnd() |
ConsistentHash |
EventImpl.getConsistentHashAtStart() |
ConsistentHash |
EventImpl.getUnionConsistentHash() |
Modifier and Type | Method and Description |
---|---|
void |
EventImpl.setConsistentHashAtEnd(ConsistentHash consistentHashAtEnd) |
void |
EventImpl.setConsistentHashAtStart(ConsistentHash consistentHashAtStart) |
void |
EventImpl.setUnionConsistentHash(ConsistentHash unionConsistentHash) |
Modifier and Type | Method and Description |
---|---|
void |
JavaLog_$logger.noMembersInHashTopology(ConsistentHash ch,
String topologyMap) |
void |
JavaLog.noMembersInHashTopology(ConsistentHash ch,
String topologyMap) |
Modifier and Type | Field and Description |
---|---|
static Consumer<ConsistentHash> |
StateTransferInterceptor.NOP
Deprecated.
|
Constructor and Description |
---|
OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
PersistenceManager persistenceManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
InternalEntryFactory ef,
long timeout,
String cacheName) |
Modifier and Type | Method and Description |
---|---|
<R> Object |
ClusterStreamManagerImpl.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<R> Object |
ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback)
Key tracking remote operation that doesn't have rehash enabled.
|
<R> Object |
ClusterStreamManagerImpl.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate)
Performs the remote stream operation without rehash awareness.
|
<R2> Object |
ClusterStreamManagerImpl.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<R2> Object |
PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<R2> Object |
ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback)
Key tracking remote operation that has rehash enabled
|
<R> Object |
ClusterStreamManagerImpl.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R> Object |
ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate)
Performs the remote stream operation with rehash awareness.
|
protected Supplier<Stream<CacheEntry>> |
AbstractCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys) |
protected Supplier<Stream<CacheEntry>> |
AbstractCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean usePrimary)
If
usePrimary is true the segments are the primary segments but only those that exist in
targetSegments. |
Constructor and Description |
---|
EntryStreamSupplier(Cache<K,V> cache,
ConsistentHash hash,
Supplier<Stream<CacheEntry<K,V>>> supplier) |
KeyStreamSupplier(Cache<K,V> cache,
ConsistentHash hash,
Supplier<Stream<K>> supplier) |
Modifier and Type | Method and Description |
---|---|
<R> Object |
TxClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,R,?> operation,
ClusterStreamManager.ResultsCallback<Collection<R>> callback) |
<R> Object |
TxClusterStreamManager.remoteStreamOperation(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
<R2> Object |
TxClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
KeyTrackingTerminalOperation<K,?,R2> operation,
ClusterStreamManager.ResultsCallback<Map<K,R2>> callback) |
<R> Object |
TxClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution,
boolean parallelStream,
ConsistentHash ch,
Set<Integer> segments,
Set<K> keysToInclude,
Map<Integer,Set<K>> keysToExclude,
boolean includeLoader,
TerminalOperation<R> operation,
ClusterStreamManager.ResultsCallback<R> callback,
Predicate<? super R> earlyTerminatePredicate) |
protected Supplier<Stream<CacheEntry>> |
TxDistributedCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean primaryOnly) |
protected Supplier<Stream<CacheEntry>> |
TxDistributedDoubleCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean primaryOnly) |
protected Supplier<Stream<CacheEntry>> |
TxDistributedLongCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean primaryOnly) |
protected Supplier<Stream<CacheEntry>> |
TxDistributedIntCacheStream.supplierForSegments(ConsistentHash ch,
Set<Integer> targetSegments,
Set<Object> excludedKeys,
boolean primaryOnly) |
Constructor and Description |
---|
TxClusterStreamManager(ClusterStreamManager<K> manager,
LocalTxInvocationContext ctx,
ConsistentHash hash) |
Modifier and Type | Method and Description |
---|---|
ConsistentHash |
CacheTopologyControlCommand.getCurrentCH() |
ConsistentHash |
CacheTopology.getCurrentCH()
The current consistent hash.
|
ConsistentHash |
CacheTopologyControlCommand.getPendingCH() |
ConsistentHash |
CacheTopology.getPendingCH()
The future consistent hash.
|
ConsistentHash |
CacheTopology.getReadConsistentHash()
Read operations should always go to the "current" owners.
|
ConsistentHash |
CacheTopology.getUnionCH()
The union of the current and future consistent hashes.
|
ConsistentHash |
CacheTopology.getWriteConsistentHash()
When there is a rebalance in progress, write operations should go to the union of the "current" and "future" owners.
|
Constructor and Description |
---|
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
ConsistentHash unionCH,
List<Address> actualMembers) |
CacheTopology(int topologyId,
int rebalanceId,
ConsistentHash currentCH,
ConsistentHash pendingCH,
List<Address> actualMembers) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.