org.infinispan.stream.impl.local

Class PersistenceEntryStreamSupplier<K,V>

java.lang.Object

org.infinispan.stream.impl.local.PersistenceEntryStreamSupplier<K,V>

All Implemented Interfaces:

AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>,Stream<CacheEntry<K,V>>>

public class PersistenceEntryStreamSupplier<K,V>
extends Object
implements AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>,Stream<CacheEntry<K,V>>>

StreamSupplier that allows for creating streams where they utilize the PersistenceManager to publish entries using segments if possible.

Since:

9.4

Author:

wburns

Constructor Summary

Constructors

Constructor and Description
PersistenceEntryStreamSupplier(Cache<K,V> cache, InternalEntryFactory iceFactory, ToIntFunction<Object> toIntFunction, CacheStream<CacheEntry<K,V>> inMemoryStream, PersistenceManager persistenceManager)

Method Summary

Modifier and Type	Method and Description
Stream<CacheEntry<K,V>>	buildStream(IntSet segmentsToFilter, Set<?> keysToFilter, boolean parallel)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistenceEntryStreamSupplier

public PersistenceEntryStreamSupplier(Cache<K,V> cache,
                                      InternalEntryFactory iceFactory,
                                      ToIntFunction<Object> toIntFunction,
                                      CacheStream<CacheEntry<K,V>> inMemoryStream,
                                      PersistenceManager persistenceManager)

Method Detail

buildStream

public Stream<CacheEntry<K,V>> buildStream(IntSet segmentsToFilter,
                                           Set<?> keysToFilter,
                                           boolean parallel)

Specified by:

buildStream in interface AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>,Stream<CacheEntry<K,V>>>