public class KeyStreamSupplier<K,V> extends Object implements AbstractLocalCacheStream.StreamSupplier<K>
Constructor and Description |
---|
KeyStreamSupplier(Cache<K,V> cache,
ConsistentHash hash,
Supplier<Stream<K>> supplier) |
Modifier and Type | Method and Description |
---|---|
Stream<K> |
buildStream(Set<Integer> segmentsToFilter,
Set<?> keysToFilter) |
CloseableIterator<K> |
removableIterator(CloseableIterator<K> realIterator) |
public Stream<K> buildStream(Set<Integer> segmentsToFilter, Set<?> keysToFilter)
buildStream
in interface AbstractLocalCacheStream.StreamSupplier<K>
public CloseableIterator<K> removableIterator(CloseableIterator<K> realIterator)
removableIterator
in interface AbstractLocalCacheStream.StreamSupplier<K>
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.