public class SegmentedKeyStreamSupplier<K,V> extends Object implements AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>
InternalDataContainer
so that
the stream only looks at keys in those given segments.Constructor and Description |
---|
SegmentedKeyStreamSupplier(Cache<K,V> cache,
ToIntFunction<Object> toIntFunction,
InternalDataContainer<K,V> internalDataContainer) |
Modifier and Type | Method and Description |
---|---|
Stream<K> |
buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
public SegmentedKeyStreamSupplier(Cache<K,V> cache, ToIntFunction<Object> toIntFunction, InternalDataContainer<K,V> internalDataContainer)
public Stream<K> buildStream(IntSet segmentsToFilter, Set<?> keysToFilter, boolean parallel)
buildStream
in interface AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>
Copyright © 2021 JBoss by Red Hat. All rights reserved.