public class PersistenceKeyStreamSupplier<K> extends Object implements AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>
PersistenceManager
to publish keys
using segments if possible.Constructor and Description |
---|
PersistenceKeyStreamSupplier(Cache<K,?> cache,
ToIntFunction<Object> toIntFunction,
CacheStream<K> inMemoryStream,
PersistenceManager persistenceManager) |
Modifier and Type | Method and Description |
---|---|
Stream<K> |
buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
public PersistenceKeyStreamSupplier(Cache<K,?> cache, ToIntFunction<Object> toIntFunction, CacheStream<K> inMemoryStream, PersistenceManager persistenceManager)
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.