org.infinispan.stream.impl.local

Class SegmentedKeyStreamSupplier<K,V>

java.lang.Object

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

All Implemented Interfaces:

AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>

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

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

Since:

9.3

Author:

wburns

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Stream<K>	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

SegmentedKeyStreamSupplier

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

Method Detail

buildStream

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

Specified by:

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