Uses of Interface
org.infinispan.commons.util.IntSet

Packages that use IntSet

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.client.hotrod	Hot Rod client API.
org.infinispan.client.hotrod.impl
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.commons.util	Commons package providing various utility classes
org.infinispan.container.impl	Data containers which store cache entries.
org.infinispan.container.offheap
org.infinispan.container.versioning.irac
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.util
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.async
org.infinispan.persistence.file	Simple filesystem-based CacheWriter implementation.
org.infinispan.persistence.internal
org.infinispan.persistence.jdbc.common	This package contains a AdvancedLoadWriteStore implementation based on a JDBC database connection.
org.infinispan.persistence.jdbc.common.impl
org.infinispan.persistence.jdbc.common.sql
org.infinispan.persistence.jdbc.stringbased	JDBC CacheStore implementation which maps keys to strings.
org.infinispan.persistence.remote	Hot Rod-based AdvancedLoadWriteStore.
org.infinispan.persistence.rocksdb	RocksDB-based AdvancedLoadWriteStore.
org.infinispan.persistence.sifs	Soft Index AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.sql	This package contains a AdvancedLoadWriteStore implementation based on a JDBC database connection.
org.infinispan.persistence.support
org.infinispan.reactive.publisher.impl
org.infinispan.scattered	SCATTERED CACHE DESIGN
org.infinispan.scattered.impl
org.infinispan.stats.impl
org.infinispan.stream.impl
org.infinispan.util	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.
org.infinispan.xsite.commands.remote
org.infinispan.xsite.irac

Uses of IntSet in org.infinispan

Methods in org.infinispan with parameters of type IntSet

Modifier and Type	Method	Description
BaseCacheStream	BaseCacheStream.filterKeySegments(IntSet segments)	Filters which entries are returned by what segment they are present in.
CacheStream<R>	CacheStream.filterKeySegments(IntSet segments)	Filters which entries are returned by what segment they are present in.
LockedStream<K,V>	LockedStream.filterKeySegments(IntSet segments)	Filters which entries are returned by what segment they are present in.
default org.reactivestreams.Publisher<E>	CacheCollection.localPublisher(IntSet segments)	Returns a publisher that will publish all elements that map to the given segment.
abstract org.reactivestreams.Publisher<E>	InternalCacheSet.localPublisher(IntSet segments)

Uses of IntSet in org.infinispan.client.hotrod

Methods in org.infinispan.client.hotrod with parameters of type IntSet

Modifier and Type	Method	Description
CloseableIteratorSet<Map.Entry<K,V>>	RemoteCache.entrySet(IntSet segments)	This method is identical to RemoteCache.entrySet() except that it will only return entries that map to the given segments.
CloseableIteratorSet<K>	RemoteCache.keySet(IntSet segments)	This method is identical to RemoteCache.keySet() except that it will only return keys that map to the given segments.
CloseableIteratorCollection<V>	RemoteCache.values(IntSet segments)	This method is identical to RemoteCache.values() except that it will only return values that map to the given segments.

Uses of IntSet in org.infinispan.client.hotrod.impl

Methods in org.infinispan.client.hotrod.impl with parameters of type IntSet

Modifier and Type	Method	Description
CloseableIterator<Map.Entry<K,V>>	DelegatingRemoteCache.entryIterator(IntSet segments)
CloseableIterator<Map.Entry<K,V>>	InternalRemoteCache.entryIterator(IntSet segments)
CloseableIterator<Map.Entry<K,V>>	RemoteCacheImpl.entryIterator(IntSet segments)
CloseableIteratorSet<Map.Entry<K,V>>	DelegatingRemoteCache.entrySet(IntSet segments)
CloseableIteratorSet<Map.Entry<K,V>>	RemoteCacheImpl.entrySet(IntSet segments)
CloseableIterator<K>	DelegatingRemoteCache.keyIterator(IntSet segments)
CloseableIterator<K>	InternalRemoteCache.keyIterator(IntSet segments)
CloseableIterator<K>	RemoteCacheImpl.keyIterator(IntSet segments)
CloseableIteratorSet<K>	DelegatingRemoteCache.keySet(IntSet segments)
CloseableIteratorSet<K>	RemoteCacheImpl.keySet(IntSet segments)
CloseableIteratorCollection<V>	DelegatingRemoteCache.values(IntSet segments)
CloseableIteratorCollection<V>	RemoteCacheImpl.values(IntSet segments)

Uses of IntSet in org.infinispan.commands

Methods in org.infinispan.commands with parameters of type IntSet

Modifier and Type	Method	Description
org.infinispan.commands.statetransfer.ConflictResolutionStartCommand	CommandsFactory.buildConflictResolutionStartCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.ConflictResolutionStartCommand	CommandsFactoryImpl.buildConflictResolutionStartCommand(int topologyId, IntSet segments)
<K, V, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactory.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K, V, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactoryImpl.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K, I, R> org.infinispan.reactive.publisher.impl.commands.batch.InitialPublisherCommand<K,I,R>	CommandsFactory.buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)
<K, I, R> org.infinispan.reactive.publisher.impl.commands.batch.InitialPublisherCommand<K,I,R>	CommandsFactoryImpl.buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)
org.infinispan.commands.irac.IracRequestStateCommand	CommandsFactory.buildIracRequestStateCommand(IntSet segments)
org.infinispan.commands.irac.IracRequestStateCommand	CommandsFactoryImpl.buildIracRequestStateCommand(IntSet segments)
<K, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactory.buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactoryImpl.buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
org.infinispan.commands.statetransfer.ScatteredStateConfirmRevokedCommand	CommandsFactory.buildScatteredStateConfirmRevokeCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.ScatteredStateConfirmRevokedCommand	CommandsFactoryImpl.buildScatteredStateConfirmRevokeCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.ScatteredStateGetKeysCommand	CommandsFactory.buildScatteredStateGetKeysCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.ScatteredStateGetKeysCommand	CommandsFactoryImpl.buildScatteredStateGetKeysCommand(int topologyId, IntSet segments)
org.infinispan.commands.read.SizeCommand	CommandsFactory.buildSizeCommand(IntSet segments, long flagsBitSet)	Builds a SizeCommand
org.infinispan.commands.read.SizeCommand	CommandsFactoryImpl.buildSizeCommand(IntSet segments, long flagsBitSet)
org.infinispan.commands.statetransfer.StateTransferCancelCommand	CommandsFactory.buildStateTransferCancelCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferCancelCommand	CommandsFactoryImpl.buildStateTransferCancelCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferGetTransactionsCommand	CommandsFactory.buildStateTransferGetTransactionsCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferGetTransactionsCommand	CommandsFactoryImpl.buildStateTransferGetTransactionsCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferStartCommand	CommandsFactory.buildStateTransferStartCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferStartCommand	CommandsFactoryImpl.buildStateTransferStartCommand(int topologyId, IntSet segments)

Uses of IntSet in org.infinispan.commons.util

Classes in org.infinispan.commons.util that implement IntSet

Modifier and Type	Class	Description
class	ImmutableIntSet	Deprecated, for removal: This API element is subject to removal in a future version. since 9.3 This class will no longer be public, please use IntSets.immutableSet(IntSet)
class	RangeSet	Deprecated, for removal: This API element is subject to removal in a future version. since 9.3 This class will no longer be public.
class	SmallIntSet	Deprecated, for removal: This API element is subject to removal in a future version. since 9.3 This class will no longer be public.

Methods in org.infinispan.commons.util that return IntSet

Modifier and Type	Method	Description
static IntSet	IntSets.concurrentCopyFrom(IntSet intSet, int maxExclusive)	Returns a copy of the given set that supports concurrent operations.
static IntSet	IntSets.concurrentSet(int maxExclusive)	Returns a concurrent mutable IntSet that can store values in the range of 0..maxExclusive-1
static IntSet	IntSets.from(byte[] bytes)
static IntSet	IntSets.from(PrimitiveIterator.OfInt iterator)	Returns an IntSet based on the ints in the iterator.
static IntSet	IntSets.from(Set<Integer> integerSet)	Returns an IntSet based on the provided Set.
IntSet	BloomFilter.getIntSet()
static IntSet	IntSets.immutableEmptySet()	Returns an immutable IntSet containing no values
static IntSet	IntSets.immutableRangeSet(int endExclusive)	Returns an immutable IntSet containing all values from 0 to endExclusive - 1.
static IntSet	IntSets.immutableSet(int value)	Returns an immutable IntSet containing a single value
static IntSet	IntSets.immutableSet(IntSet set)	Returns an immutable IntSet that wraps the given IntSet to prevent modifications.
static IntSet	IntSets.mutableCopyFrom(Set<Integer> mutableSet)	Returns an IntSet that contains all ints from the given Set that is mutable.
static IntSet	IntSets.mutableEmptySet()	Returns a mutable IntSet with no values set.
static IntSet	IntSets.mutableEmptySet(int maxExclusive)	Returns an IntSet that contains no values but is initialized to hold ints equal to the maxExclusive -1 or smaller.
static IntSet	IntSets.mutableFrom(Set<Integer> integerSet)	Returns an IntSet that is mutable that contains all of the values from the given set.
static IntSet	IntSets.mutableSet(int value)	Returns a mutable set with the initial value set.
static IntSet	IntSets.mutableSet(int value1, int value2)	Returns a mutable IntSet that begins with the initialized values
static IntSet	IntSetsExternalization.readFrom(ObjectInput input)

Methods in org.infinispan.commons.util that return types with arguments of type IntSet

Modifier and Type	Method	Description
static Set<Class<? extends IntSet>>	IntSetsExternalization.getTypeClasses()

Methods in org.infinispan.commons.util with parameters of type IntSet

Modifier and Type	Method	Description
boolean	ImmutableIntSet.addAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	IntSet.addAll(IntSet set)	Adds all ints from the provided set into this one
boolean	RangeSet.addAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	SmallIntSet.addAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
static IntSet	IntSets.concurrentCopyFrom(IntSet intSet, int maxExclusive)	Returns a copy of the given set that supports concurrent operations.
boolean	ImmutableIntSet.containsAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	IntSet.containsAll(IntSet set)	Whether this set contains all ints in the given IntSet
boolean	RangeSet.containsAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	SmallIntSet.containsAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
static IntSet	IntSets.immutableSet(IntSet set)	Returns an immutable IntSet that wraps the given IntSet to prevent modifications.
boolean	IntSet.removeAll(IntSet set)	Removes all ints from this IntSet that are in the provided IntSet
boolean	RangeSet.removeAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	SmallIntSet.removeAll(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	IntSet.retainAll(IntSet c)	Modifies this set to remove all ints that are not present in the provided IntSet
boolean	RangeSet.retainAll(IntSet c)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	SmallIntSet.retainAll(IntSet c)	Deprecated, for removal: This API element is subject to removal in a future version.
void	BloomFilter.setBits(IntSet intSet)	Clears all current bits and sets them to the values in the provided IntSet.
static void	IntSetsExternalization.writeTo(ObjectOutput output, IntSet intSet)

Constructors in org.infinispan.commons.util with parameters of type IntSet

Modifier	Constructor	Description
	ImmutableIntSet(IntSet set)	Deprecated, for removal: This API element is subject to removal in a future version.

Uses of IntSet in org.infinispan.container.impl

Methods in org.infinispan.container.impl with parameters of type IntSet

Modifier and Type	Method	Description
void	AbstractDelegatingInternalDataContainer.addSegments(IntSet segments)
void	DefaultDataContainer.addSegments(IntSet segments)
void	DefaultSegmentedDataContainer.addSegments(IntSet segments)
void	InternalDataContainer.addSegments(IntSet segments)	Sets what segments this data container should be using.
void	AbstractDelegatingInternalDataContainer.clear(IntSet segments)
void	AbstractInternalDataContainer.clear(IntSet segments)
void	BoundedSegmentedDataContainer.clear(IntSet segments)
void	DefaultDataContainer.clear(IntSet segments)
void	InternalDataContainer.clear(IntSet segments)	Removes entries from the container whose key maps to one of the provided segments
void	L1SegmentedDataContainer.clear(IntSet segments)	Removes all entries that map to the given segments
void	AbstractDelegatingInternalDataContainer.forEach(IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)
void	DefaultSegmentedDataContainer.forEach(IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)
default void	InternalDataContainer.forEach(IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)	Performs the given action for each element of the container that maps to the given set of segments until all elements have been processed or the action throws an exception.
Iterator<InternalCacheEntry<K,V>>	AbstractDelegatingInternalDataContainer.iterator(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	DefaultDataContainer.iterator(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	DefaultSegmentedDataContainer.iterator(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	InternalDataContainer.iterator(IntSet segments)	Same as DataContainer.iterator() except that only entries that map to the provided segments are returned via the iterator.
Iterator<InternalCacheEntry<K,V>>	AbstractDelegatingInternalDataContainer.iteratorIncludingExpired(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	BoundedSegmentedDataContainer.iteratorIncludingExpired(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	DefaultDataContainer.iteratorIncludingExpired(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	DefaultSegmentedDataContainer.iteratorIncludingExpired(IntSet segments)
Iterator<InternalCacheEntry<K,V>>	InternalDataContainer.iteratorIncludingExpired(IntSet segments)	Same as DataContainer.iteratorIncludingExpired() except that only entries that map to the provided segments are returned via the iterator.
Iterator<InternalCacheEntry<K,V>>	L1SegmentedDataContainer.iteratorIncludingExpired(IntSet segments)
org.reactivestreams.Publisher<InternalCacheEntry<K,V>>	DefaultDataContainer.publisher(IntSet segments)
org.reactivestreams.Publisher<InternalCacheEntry<K,V>>	DefaultSegmentedDataContainer.publisher(IntSet segments)
default org.reactivestreams.Publisher<InternalCacheEntry<K,V>>	InternalDataContainer.publisher(IntSet segments)
void	AbstractDelegatingInternalDataContainer.removeSegments(IntSet segments)
void	BoundedSegmentedDataContainer.removeSegments(IntSet segments)
void	DefaultDataContainer.removeSegments(IntSet segments)
void	DefaultSegmentedDataContainer.removeSegments(IntSet segments)
void	InternalDataContainer.removeSegments(IntSet segments)	Removes and un-associates the given segments.
void	L1SegmentedDataContainer.removeSegments(IntSet segments)
int	AbstractDelegatingInternalDataContainer.size(IntSet segments)
default int	InternalDataContainer.size(IntSet segments)	Returns how many entries are present in the data container that map to the given segments without counting entries that are currently expired.
int	AbstractDelegatingInternalDataContainer.sizeIncludingExpired(IntSet segments)
int	DefaultSegmentedDataContainer.sizeIncludingExpired(IntSet segment)
default int	InternalDataContainer.sizeIncludingExpired(IntSet segments)	Returns how many entries are present in the data container that map to the given segments including any entries that may be expired
Spliterator<InternalCacheEntry<K,V>>	AbstractDelegatingInternalDataContainer.spliterator(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	DefaultDataContainer.spliterator(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	DefaultSegmentedDataContainer.spliterator(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	InternalDataContainer.spliterator(IntSet segments)	Same as DataContainer.spliterator() except that only entries that map to the provided segments are returned via this spliterator.
Spliterator<InternalCacheEntry<K,V>>	AbstractDelegatingInternalDataContainer.spliteratorIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	BoundedSegmentedDataContainer.spliteratorIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	DefaultDataContainer.spliteratorIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	DefaultSegmentedDataContainer.spliteratorIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<K,V>>	InternalDataContainer.spliteratorIncludingExpired(IntSet segments)	Same as DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided segments are returned via this spliterator.
Spliterator<InternalCacheEntry<K,V>>	L1SegmentedDataContainer.spliteratorIncludingExpired(IntSet segments)

Uses of IntSet in org.infinispan.container.offheap

Methods in org.infinispan.container.offheap with parameters of type IntSet

Modifier and Type	Method	Description
void	BoundedOffHeapDataContainer.addSegments(IntSet segments)
void	OffHeapDataContainer.addSegments(IntSet segments)
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	BoundedOffHeapDataContainer.iterator(IntSet segments)
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	OffHeapDataContainer.iterator(IntSet segments)
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	BoundedOffHeapDataContainer.iteratorIncludingExpired(IntSet segments)
Iterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	OffHeapDataContainer.iteratorIncludingExpired(IntSet segments)
void	BoundedOffHeapDataContainer.removeSegments(IntSet segments)
void	OffHeapDataContainer.removeSegments(IntSet segments)
int	BoundedOffHeapDataContainer.size(IntSet segments)
int	BoundedOffHeapDataContainer.sizeIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	BoundedOffHeapDataContainer.spliterator(IntSet segments)
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	OffHeapDataContainer.spliterator(IntSet segments)
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	BoundedOffHeapDataContainer.spliteratorIncludingExpired(IntSet segments)
Spliterator<InternalCacheEntry<WrappedBytes,WrappedBytes>>	OffHeapDataContainer.spliteratorIncludingExpired(IntSet segments)

Uses of IntSet in org.infinispan.container.versioning.irac

Methods in org.infinispan.container.versioning.irac with parameters of type IntSet

Modifier and Type	Method	Description
void	DefaultIracTombstoneManager.sendStateTo(Address requestor, IntSet segments)
void	IracTombstoneManager.sendStateTo(Address requestor, IntSet segments)	Sends the tombstone belonging to the segments in segment to the originator
void	NoOpIracTombstoneManager.sendStateTo(Address requestor, IntSet segments)

Uses of IntSet in org.infinispan.distribution

Methods in org.infinispan.distribution that return IntSet

Modifier and Type	Method	Description
IntSet	LocalizedCacheTopology.getLocalPrimarySegments()
IntSet	LocalizedCacheTopology.getLocalReadSegments()
IntSet	LocalizedCacheTopology.getLocalWriteSegments()

Uses of IntSet in org.infinispan.distribution.util

Fields in org.infinispan.distribution.util declared as IntSet

Modifier and Type	Field	Description
protected final IntSet	ReadOnlySegmentAwareCollection.allowedSegments
protected final IntSet	ReadOnlySegmentAwareIterator.allowedSegments
protected final IntSet	ReadOnlySegmentAwareMap.allowedSegments

Constructors in org.infinispan.distribution.util with parameters of type IntSet

Modifier	Constructor	Description
	ReadOnlySegmentAwareCollection(Collection<E> set, LocalizedCacheTopology topology, IntSet allowedSegments)
	ReadOnlySegmentAwareEntryCollection(Set<Map.Entry<K,V>> set, LocalizedCacheTopology topology, IntSet allowedSegments)
	ReadOnlySegmentAwareEntryIterator(Iterator<Map.Entry<K,V>> iter, LocalizedCacheTopology topology, IntSet allowedSegments)
	ReadOnlySegmentAwareIterator(Iterator<E> iter, LocalizedCacheTopology topology, IntSet allowedSegments)
	ReadOnlySegmentAwareMap(Map<K,V> map, LocalizedCacheTopology topology, IntSet allowedSegments)

Uses of IntSet in org.infinispan.persistence

Methods in org.infinispan.persistence with parameters of type IntSet

Modifier and Type	Method	Description
static int	PersistenceUtil.count(SegmentedAdvancedLoadWriteStore<?,?> salws, IntSet segments)	Counts how many entries are present in the segmented store.
static <R> org.reactivestreams.Publisher<R>	PersistenceUtil.parallelizePublisher(IntSet segments, Executor executor, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)	Will create a publisher that parallelizes each publisher returned from the publisherFunction by executing them on the executor as needed.
static <K, V> Set<K>	PersistenceUtil.toKeySet(NonBlockingStore<K,V> nonBlockingStore, IntSet segments, Predicate<? super K> filter)

Uses of IntSet in org.infinispan.persistence.async

Methods in org.infinispan.persistence.async with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	AsyncNonBlockingStore.addSegments(IntSet segments)
CompletionStage<Long>	AsyncNonBlockingStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	AsyncNonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	AsyncNonBlockingStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Void>	AsyncNonBlockingStore.removeSegments(IntSet segments)
CompletionStage<Long>	AsyncNonBlockingStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.file

Methods in org.infinispan.persistence.file with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	SingleFileStore.addSegments(IntSet segments)
CompletionStage<Long>	SingleFileStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SingleFileStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	SingleFileStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Void>	SingleFileStore.removeSegments(IntSet segments)
CompletionStage<Long>	SingleFileStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.internal

Methods in org.infinispan.persistence.internal with parameters of type IntSet

Modifier and Type	Method	Description
static <K> Predicate<? super K>	PersistenceUtil.combinePredicate(IntSet segments, KeyPartitioner keyPartitioner, Predicate<? super K> filter)
static <R> io.reactivex.rxjava3.core.Flowable<R>	PersistenceUtil.parallelizePublisher(IntSet segments, io.reactivex.rxjava3.core.Scheduler scheduler, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)

Uses of IntSet in org.infinispan.persistence.jdbc.common

Methods in org.infinispan.persistence.jdbc.common with parameters of type IntSet

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	TableOperations.publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)
default io.reactivex.rxjava3.core.Flowable<K>	TableOperations.publishKeys(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter)

Uses of IntSet in org.infinispan.persistence.jdbc.common.impl

Methods in org.infinispan.persistence.jdbc.common.impl with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Long>	BaseJdbcStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	BaseJdbcStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	BaseJdbcStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Long>	BaseJdbcStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.jdbc.common.sql

Methods in org.infinispan.persistence.jdbc.common.sql with parameters of type IntSet

Modifier and Type	Method	Description
abstract String	BaseTableOperations.getSelectAllSql(IntSet segments)
protected void	BaseTableOperations.preparePublishStatement(PreparedStatement ps, IntSet segments)
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	BaseTableOperations.publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)

Uses of IntSet in org.infinispan.persistence.jdbc.stringbased

Methods in org.infinispan.persistence.jdbc.stringbased with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	JdbcStringBasedStore.addSegments(IntSet segments)
CompletionStage<Long>	JdbcStringBasedStore.approximateSize(IntSet segments)
CompletionStage<Void>	JdbcStringBasedStore.removeSegments(IntSet segments)
CompletionStage<Long>	JdbcStringBasedStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.remote

Methods in org.infinispan.persistence.remote with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	RemoteStore.addSegments(IntSet segments)
CompletionStage<Long>	RemoteStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RemoteStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
io.reactivex.rxjava3.core.Flowable<K>	RemoteStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Void>	RemoteStore.removeSegments(IntSet segments)
CompletionStage<Long>	RemoteStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.rocksdb

Methods in org.infinispan.persistence.rocksdb with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	RocksDBStore.addSegments(IntSet segments)
CompletionStage<Long>	RocksDBStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	RocksDBStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	RocksDBStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Void>	RocksDBStore.removeSegments(IntSet segments)
CompletionStage<Long>	RocksDBStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.sifs

Methods in org.infinispan.persistence.sifs with parameters of type IntSet

Modifier and Type	Method	Description
CompletionStage<Void>	NonBlockingSoftIndexFileStore.addSegments(IntSet segments)
void	TemporaryTable.addSegments(IntSet segments)
CompletionStage<Long>	NonBlockingSoftIndexFileStore.approximateSize(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingSoftIndexFileStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	NonBlockingSoftIndexFileStore.publishKeys(IntSet segments, Predicate<? super K> filter)
CompletionStage<Void>	NonBlockingSoftIndexFileStore.removeSegments(IntSet segments)
void	TemporaryTable.removeSegments(IntSet segments)
CompletionStage<Long>	NonBlockingSoftIndexFileStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.spi

Methods in org.infinispan.persistence.spi with parameters of type IntSet

Modifier and Type	Method	Description
default CompletionStage<Void>	NonBlockingStore.addSegments(IntSet segments)	Invoked when a node becomes an owner of the given segments.
default void	SegmentedAdvancedLoadWriteStore.addSegments(IntSet segments)	Deprecated, for removal: This API element is subject to removal in a future version. Invoked when a node becomes an owner of the given segments.
default CompletionStage<Long>	NonBlockingStore.approximateSize(IntSet segments)	Returns an estimation of the amount of entries that map to the given segments in the store.
void	SegmentedAdvancedLoadWriteStore.clear(IntSet segments)	Deprecated, for removal: This API element is subject to removal in a future version. Removes all the data that maps to the given segments from the storage.
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	SegmentedAdvancedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)	Deprecated, for removal: This API element is subject to removal in a future version. Publishes all entries from this store.
default org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)	Publishes entries from this store that are in one of the provided segments and also pass the provided filter.
default org.reactivestreams.Publisher<K>	NonBlockingStore.publishKeys(IntSet segments, Predicate<? super K> filter)	Publishes keys from this store that are in one of the provided segments and also pass the provided filter.
org.reactivestreams.Publisher<K>	SegmentedAdvancedLoadWriteStore.publishKeys(IntSet segments, Predicate<? super K> filter)	Deprecated, for removal: This API element is subject to removal in a future version. Publishes all the keys that map to the given segments from this store.
default CompletionStage<Void>	NonBlockingStore.removeSegments(IntSet segments)	Invoked when a node loses ownership of the given segments.
default void	SegmentedAdvancedLoadWriteStore.removeSegments(IntSet segments)	Deprecated, for removal: This API element is subject to removal in a future version. Invoked when a node loses ownership of a segment.
default CompletionStage<Long>	NonBlockingStore.size(IntSet segments)	Returns the amount of entries that map to the given segments in the store.
int	SegmentedAdvancedLoadWriteStore.size(IntSet segments)	Deprecated, for removal: This API element is subject to removal in a future version. Returns the number of elements in the store that map to the given segments that aren't expired.

Uses of IntSet in org.infinispan.persistence.sql

Methods in org.infinispan.persistence.sql with parameters of type IntSet

Modifier and Type	Method	Description
String	QueriesJdbcStore.QueryTableOperations.getSelectAllSql(IntSet segments)
String	TableJdbcStore.TableTableOperations.getSelectAllSql(IntSet segments)

Uses of IntSet in org.infinispan.persistence.support

Methods in org.infinispan.persistence.support with parameters of type IntSet

Modifier and Type	Method	Description
void	ComposedSegmentedLoadWriteStore.addSegments(IntSet segments)
CompletionStage<Void>	DelegatingNonBlockingStore.addSegments(IntSet segments)
CompletionStage<Boolean>	DelegatingPersistenceManager.addSegments(IntSet segments)
CompletionStage<Void>	NonBlockingStoreAdapter.addSegments(IntSet segments)
CompletionStage<Long>	DelegatingNonBlockingStore.approximateSize(IntSet segments)
CompletionStage<Long>	DelegatingPersistenceManager.approximateSize(Predicate<? super StoreConfiguration> predicate, IntSet segments)
CompletionStage<Long>	NonBlockingStoreAdapter.approximateSize(IntSet segments)
void	ComposedSegmentedLoadWriteStore.clear(IntSet segments)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	ComposedSegmentedLoadWriteStore.entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingNonBlockingStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
<K, V> org.reactivestreams.Publisher<MarshallableEntry<K,V>>	DelegatingPersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
org.reactivestreams.Publisher<MarshallableEntry<K,V>>	NonBlockingStoreAdapter.publishEntries(IntSet segments, Predicate<? super K> filter, boolean includeValues)
org.reactivestreams.Publisher<K>	ComposedSegmentedLoadWriteStore.publishKeys(IntSet segments, Predicate<? super K> filter)
org.reactivestreams.Publisher<K>	DelegatingNonBlockingStore.publishKeys(IntSet segments, Predicate<? super K> filter)
<K> org.reactivestreams.Publisher<K>	DelegatingPersistenceManager.publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
org.reactivestreams.Publisher<K>	NonBlockingStoreAdapter.publishKeys(IntSet segments, Predicate<? super K> filter)
void	ComposedSegmentedLoadWriteStore.removeSegments(IntSet segments)
CompletionStage<Void>	DelegatingNonBlockingStore.removeSegments(IntSet segments)
CompletionStage<Boolean>	DelegatingPersistenceManager.removeSegments(IntSet segments)
CompletionStage<Void>	NonBlockingStoreAdapter.removeSegments(IntSet segments)
int	ComposedSegmentedLoadWriteStore.size(IntSet segments)
CompletionStage<Long>	DelegatingNonBlockingStore.size(IntSet segments)
CompletionStage<Long>	DelegatingPersistenceManager.size(Predicate<? super StoreConfiguration> predicate, IntSet segments)
CompletionStage<Long>	NonBlockingStoreAdapter.size(IntSet segments)

Uses of IntSet in org.infinispan.reactive.publisher.impl

Methods in org.infinispan.reactive.publisher.impl with parameters of type IntSet

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache that is local, resulting in a stream of values of possibly varying size.
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Performs the given transformer and finalizer on data in the cache, resulting in a single value.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Performs the given transformer and finalizer on data in the cache that is local, resulting in a single value.
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
protected <I, R> io.reactivex.rxjava3.core.Flowable<R>	LocalPublisherManagerImpl.exactlyOnceParallel(CacheSet<I> set, Set<K> keysToExclude, Function<I,K> toKeyFunction, IntSet segments, Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> collator, LocalPublisherManagerImpl<K,V>.org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener, IntSet concurrentSegments)	This method iteratively submits a task to operate on the cpu bound thread pool up to the number of cores - 1.
protected <I, R> io.reactivex.rxjava3.core.Flowable<R>	LocalPublisherManagerImpl.exactlyOnceSequential(CacheSet<I> set, Set<K> keysToExclude, Function<I,K> toKeyFunction, IntSet segments, Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> collator, LocalPublisherManagerImpl<K,V>.org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener, IntSet concurrentSegments)
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)	Same as ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, long, DeliveryGuarantee, int, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)	Same as LocalPublisherManager.entryPublisher(IntSet, Set, Set, long, DeliveryGuarantee, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Same as ClusterPublisherManager.entryReduction(boolean, IntSet, Set, InvocationContext, long, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Same as LocalPublisherManager.entryReduction(boolean, IntSet, Set, Set, long, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
void	LocalPublisherManager.segmentsLost(IntSet lostSegments)	Method to invoke when a set of segments are being removed from this node.
void	LocalPublisherManagerImpl.segmentsLost(IntSet lostSegments)
CompletionStage<Long>	ClusterPublisherManager.sizePublisher(IntSet segments, InvocationContext ctx, long flags)
CompletionStage<Long>	ClusterPublisherManagerImpl.sizePublisher(IntSet segments, InvocationContext ctx, long flags)
CompletionStage<Long>	LocalClusterPublisherManagerImpl.sizePublisher(IntSet segments, InvocationContext ctx, long flags)
CompletionStage<Long>	LocalPublisherManager.sizePublisher(IntSet segments, long flags)
CompletionStage<Long>	LocalPublisherManagerImpl.sizePublisher(IntSet segments, long flags)

Constructor parameters in org.infinispan.reactive.publisher.impl with type arguments of type IntSet

Modifier	Constructor	Description
	InnerPublisherSubscriptionBuilder(ClusterPublisherManagerImpl<K,?>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SubscriberHandler<I,R> parent, int batchSize, Supplier<Map.Entry<Address,IntSet>> supplier, Map<Address,Set<K>> excludedKeys, int topologyId)

Uses of IntSet in org.infinispan.scattered

Methods in org.infinispan.scattered with parameters of type IntSet

Modifier and Type	Method	Description
void	BiasManager.revokeLocalBiasForSegments(IntSet segments)	Stop reading local data from this segment.
void	ScatteredVersionManager.setOwnedSegments(IntSet segments)	Move the segment from ScatteredVersionManager.SegmentState.NOT_OWNED to ScatteredVersionManager.SegmentState.OWNED without transferring data.
void	ScatteredStateProvider.startKeysTransfer(IntSet segments, Address origin)	Start transferring keys and remote metadata for the given segments to the origin.
void	ScatteredVersionManager.startKeyTransfer(IntSet segments)	Move the segments from ScatteredVersionManager.SegmentState.BLOCKED to ScatteredVersionManager.SegmentState.KEY_TRANSFER state.

Uses of IntSet in org.infinispan.scattered.impl

Fields in org.infinispan.scattered.impl declared as IntSet

Modifier and Type	Field	Description
protected IntSet	ScatteredStateConsumerImpl.inboundSegments

Methods in org.infinispan.scattered.impl with parameters of type IntSet

Modifier and Type	Method	Description
protected CompletionStage<Void>	ScatteredStateConsumerImpl.handleSegments(boolean isRebalance, IntSet addedSegments, IntSet transactionOnlySegments)
protected CompletionStage<Void>	ScatteredStateConsumerImpl.removeStaleData(IntSet removedSegments)
void	BiasManagerImpl.revokeLocalBiasForSegments(IntSet segments)
void	ScatteredVersionManagerImpl.setOwnedSegments(IntSet segments)
void	ScatteredStateProviderImpl.startKeysTransfer(IntSet segments, Address origin)
void	ScatteredVersionManagerImpl.startKeyTransfer(IntSet segments)

Uses of IntSet in org.infinispan.stats.impl

Fields in org.infinispan.stats.impl declared as IntSet

Modifier and Type	Field	Description
static final IntSet	StatsCollector.SEGMENT_0

Uses of IntSet in org.infinispan.stream.impl

Fields in org.infinispan.stream.impl declared as IntSet

Modifier and Type	Field	Description
protected IntSet	AbstractCacheStream.segmentsToFilter

Methods in org.infinispan.stream.impl with parameters of type IntSet

Modifier and Type	Method	Description
CacheStream<R>	DistributedCacheStream.filterKeySegments(IntSet segments)
DoubleCacheStream	DistributedDoubleCacheStream.filterKeySegments(IntSet segments)
IntCacheStream	DistributedIntCacheStream.filterKeySegments(IntSet segments)
LongCacheStream	DistributedLongCacheStream.filterKeySegments(IntSet segments)
CacheStream<R>	IntermediateCacheStream.filterKeySegments(IntSet segments)
DoubleCacheStream	IntermediateDoubleCacheStream.filterKeySegments(IntSet segments)
IntCacheStream	IntermediateIntCacheStream.filterKeySegments(IntSet segments)
LongCacheStream	IntermediateLongCacheStream.filterKeySegments(IntSet segments)
LockedStream<K,V>	LockedStreamImpl.filterKeySegments(IntSet segments)

Uses of IntSet in org.infinispan.util

Methods in org.infinispan.util that return IntSet

Modifier and Type	Method	Description
IntSet	IntSetExternalizer.readObject(ObjectInput input)

Methods in org.infinispan.util that return types with arguments of type IntSet

Modifier and Type	Method	Description
Set<Class<? extends IntSet>>	IntSetExternalizer.getTypeClasses()

Methods in org.infinispan.util with parameters of type IntSet

Modifier and Type	Method	Description
AbstractDelegatingCacheStream<R>	AbstractDelegatingCacheStream.filterKeySegments(IntSet segments)
void	IntSetExternalizer.writeObject(ObjectOutput output, IntSet intSet)

Uses of IntSet in org.infinispan.xsite.commands.remote

Methods in org.infinispan.xsite.commands.remote that return types with arguments of type IntSet

Modifier and Type	Method	Description
CompletionStage<IntSet>	IracPutManyRequest.executeOperation(org.infinispan.xsite.BackupReceiver receiver)
protected CompletionStage<IntSet>	IracTombstoneCheckRequest.invokeInLocalCache(String origin, ComponentRegistry registry)
XSiteRequest<IntSet>	IracPutManyRequest.readFrom(ObjectInput input)
XSiteRequest<IntSet>	IracTombstoneCheckRequest.readFrom(ObjectInput input)

Uses of IntSet in org.infinispan.xsite.irac

Methods in org.infinispan.xsite.irac with parameters of type IntSet

Modifier and Type	Method	Description
void	DefaultIracManager.requestState(Address requestor, IntSet segments)
void	IracManager.requestState(Address requestor, IntSet segments)	Requests the state stored in this instance for the given segments.
void	NoOpIracManager.requestState(Address requestor, IntSet segments)

Method parameters in org.infinispan.xsite.irac with type arguments of type IntSet

Modifier and Type	Method	Description
void	IracResponseCollector.dependsOn(IracXSiteBackup backup, CompletionStage<? extends IntSet> request)