Collection.stream()
method on either Cache.entrySet()
,
Cache.keySet()
or Cache.values()
. The CacheFilters
can be used to
bridge between filter/converters and proper stream typespublic interface EntryRetriever<K,V>
Modifier and Type | Interface and Description |
---|---|
static interface |
EntryRetriever.SegmentListener
Deprecated.
This interface describes the call back methods that are invoked when an iteration process completes segments
and finally completes.
|
Modifier and Type | Method and Description |
---|---|
<C> void |
receiveResponse(UUID identifier,
Address origin,
Set<Integer> completedSegments,
Set<Integer> inDoubtSegments,
Collection<CacheEntry<K,C>> entries,
CacheException e)
Deprecated.
This method is invoked on the local node who started the iteration process for each batch of values.
|
<C> CloseableIterator<CacheEntry<K,C>> |
retrieveEntries(KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
Set<Flag> flags,
EntryRetriever.SegmentListener listener)
Deprecated.
This is invoked locally on the node that requested the iteration process.
|
<C> void |
startRetrievingValues(UUID identifier,
Address origin,
Set<Integer> segments,
Set<K> keysToFilter,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,C> converter,
Set<Flag> flagss)
Deprecated.
This method is intended to be ran remotely on a node who has segments that the values have been requested.
|
<C> void startRetrievingValues(UUID identifier, Address origin, Set<Integer> segments, Set<K> keysToFilter, KeyValueFilter<? super K,? super V> filter, Converter<? super K,? super V,C> converter, Set<Flag> flagss)
C
- The resulting type of the Converteridentifier
- The unique identifier of the iteration requestorigin
- The node that sent the iteration requestsegments
- The segments this node wantskeysToFilter
- The keys to filter out (can be null
)filter
- The filter to be applied to determine if a value should be usedconverter
- The converter to run on the values retrieved before returning<C> void receiveResponse(UUID identifier, Address origin, Set<Integer> completedSegments, Set<Integer> inDoubtSegments, Collection<CacheEntry<K,C>> entries, CacheException e)
completedSegments
or inDoubtSegments
is not empty (not both could be as well) then the
iteration process on this node is complete.C
- The type of entries values sent backidentifier
- The unique identifier of the iteration requestorigin
- The node where the response came fromcompletedSegments
- Which segments have been completedinDoubtSegments
- Which segments are now in doubt due to a rehashentries
- The entries retrievede
- If an exception handled while processing the data on the remote node<C> CloseableIterator<CacheEntry<K,C>> retrieveEntries(KeyValueFilter<? super K,? super V> filter, Converter<? super K,? super V,? extends C> converter, Set<Flag> flags, EntryRetriever.SegmentListener listener)
C
- The type of the resulting values from the converterfilter
- An optional filter that will be ran on each key/value to determine if it should be returned.converter
- An optional converter that will be ran on each key/value that will be returned to transform
the value to a different value if desiredflags
- An optional set of flags to modify behavior. For example Flag.CACHE_MODE_LOCAL
will prevent
the retriever from retrieving remote values and Flag.SKIP_CACHE_LOAD
will prevent the
retriever from getting values from the configured loader if present.listener
- An optional segment listener that can be used to tell the invoker when segments and the iteration
process is completedCopyright © 2024 JBoss, a division of Red Hat. All rights reserved.