K
- key type for the entry returnedR
- return type when not utilizing rehash awareR2
- value type for the entry returnedpublic interface KeyTrackingTerminalOperation<K,R,R2> extends SegmentAwareOperation
CacheStream
that allows tracking keys during a rehash event.Modifier and Type | Interface and Description |
---|---|
static interface |
KeyTrackingTerminalOperation.IntermediateCollector<C>
Collector used to collect items from intermediate responses of operations
|
Modifier and Type | Method and Description |
---|---|
void |
handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.
|
Collection<R> |
performOperation(KeyTrackingTerminalOperation.IntermediateCollector<Collection<R>> response)
Invoked when a key aware operation is desired without rehash being enabled.
|
Collection<CacheEntry<K,R2>> |
performOperationRehashAware(KeyTrackingTerminalOperation.IntermediateCollector<Collection<CacheEntry<K,R2>>> response)
Invoked when a key and rehash aware operation is desired.
|
void |
setSupplier(Supplier<? extends Stream<?>> supplier)
This method is to be invoked only locally after a key tracking operation has been serialized to a new node
|
lostSegment
Collection<R> performOperation(KeyTrackingTerminalOperation.IntermediateCollector<Collection<R>> response)
response
- the collector that will be called back for any intermediate resultsCollection<CacheEntry<K,R2>> performOperationRehashAware(KeyTrackingTerminalOperation.IntermediateCollector<Collection<CacheEntry<K,R2>>> response)
response
- the collector that will be called back for any intermediate resultsvoid setSupplier(Supplier<? extends Stream<?>> supplier)
supplier
- the supplier to usevoid handleInjection(ComponentRegistry registry)
registry
- component registry to useCopyright © 2021 JBoss, a division of Red Hat. All rights reserved.