public class EntryStreamSupplier<K,V> extends Object implements AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>>
CacheEntry
instances. This
supplier will do the proper filtering by key based on the CacheEntry key.Constructor and Description |
---|
EntryStreamSupplier(Cache<K,V> cache,
ConsistentHash hash,
Supplier<Stream<CacheEntry<K,V>>> supplier) |
Modifier and Type | Method and Description |
---|---|
Stream<CacheEntry<K,V>> |
buildStream(Set<Integer> segmentsToFilter,
Set<?> keysToFilter) |
CloseableIterator<CacheEntry<K,V>> |
removableIterator(CloseableIterator<CacheEntry<K,V>> realIterator) |
public EntryStreamSupplier(Cache<K,V> cache, ConsistentHash hash, Supplier<Stream<CacheEntry<K,V>>> supplier)
public Stream<CacheEntry<K,V>> buildStream(Set<Integer> segmentsToFilter, Set<?> keysToFilter)
buildStream
in interface AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>>
public CloseableIterator<CacheEntry<K,V>> removableIterator(CloseableIterator<CacheEntry<K,V>> realIterator)
removableIterator
in interface AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>>
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.