org.infinispan.stream.impl.local

Class SegmentedEntryStreamSupplier<K,V>

java.lang.Object

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

All Implemented Interfaces:

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

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

StreamSupplier that allows for creating streams where they utilize a InternalDataContainer so that the stream only looks at entries in those given segments.

Since:

9.3

Author:

wburns

Constructor Summary

Constructors

Constructor and Description
SegmentedEntryStreamSupplier(Cache<K,V> cache, ToIntFunction<Object> toIntFunction, InternalDataContainer<K,V> internalDataContainer)

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

SegmentedEntryStreamSupplier

public SegmentedEntryStreamSupplier(Cache<K,V> cache,
                                    ToIntFunction<Object> toIntFunction,
                                    InternalDataContainer<K,V> internalDataContainer)

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>>>