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.cache.impl
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 NonBlockingStore implementation.
org.infinispan.persistence.internal
org.infinispan.persistence.jdbc.common	This package contains a NonBlockingStore 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 NonBlockingStore.
org.infinispan.persistence.rocksdb	RocksDB-based NonBlockingStore.
org.infinispan.persistence.sifs	Soft Index NonBlockingStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.sql	This package contains a NonBlockingStore implementation based on a JDBC database connection.
org.infinispan.persistence.support
org.infinispan.reactive.publisher.impl
org.infinispan.server.iteration.list
org.infinispan.server.iteration.map
org.infinispan.server.resp.commands.cluster
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.util.logging	Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
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)
CachePublisher<K,V>	CachePublisher.withSegments(IntSet segments)	Configures the publisher to only publish keys or values that map to a given segment in the provided IntSet.

Uses of IntSet in org.infinispan.cache.impl

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

Modifier and Type	Method	Description
CachePublisher<K,V>	CachePublisherImpl.withSegments(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.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	ConcurrentSmallIntSet	Concurrent implementation of an IntSet.
class	EmptyIntSet	Immutable empty IntSet
class	RangeSet	Read-only set representing all the integers from 0 to size - 1 (inclusive).
class	SingletonIntSet	Immutable implementation of IntSet that contains a single value
class	SmallIntSet	Represent a set of integers (e.g. segments) as a BitSet.

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.immutableOffsetIntSet(int start, int exclusiveEnd)	Creates an immutable IntSet containing all values from to .
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

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

Modifier and Type	Method	Description
boolean	ConcurrentSmallIntSet.addAll(IntSet set)
boolean	IntSet.addAll(IntSet set)	Adds all ints from the provided set into this one
boolean	RangeSet.addAll(IntSet set)
boolean	SmallIntSet.addAll(IntSet set)
static IntSet	IntSets.concurrentCopyFrom(IntSet intSet, int maxExclusive)	Returns a copy of the given set that supports concurrent operations.
boolean	ConcurrentSmallIntSet.containsAll(IntSet set)
boolean	EmptyIntSet.containsAll(IntSet set)
boolean	IntSet.containsAll(IntSet set)	Whether this set contains all ints in the given IntSet
boolean	RangeSet.containsAll(IntSet set)
boolean	SingletonIntSet.containsAll(IntSet set)
boolean	SmallIntSet.containsAll(IntSet set)
static IntSet	IntSets.immutableSet(IntSet set)	Returns an immutable IntSet that wraps the given IntSet to prevent modifications.
boolean	ConcurrentSmallIntSet.removeAll(IntSet set)
boolean	IntSet.removeAll(IntSet set)	Removes all ints from this IntSet that are in the provided IntSet
boolean	RangeSet.removeAll(IntSet set)
boolean	SmallIntSet.removeAll(IntSet set)
boolean	ConcurrentSmallIntSet.retainAll(IntSet set)
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)
boolean	SmallIntSet.retainAll(IntSet c)
void	BloomFilter.setBits(IntSet intSet)	Clears all current bits and sets them to the values in the provided IntSet.

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 <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 CompletionStage<Long>	NonBlockingStore.approximateSize(IntSet segments)	Returns an estimation of the amount of entries that map to the given segments in the 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.
default CompletionStage<Void>	NonBlockingStore.removeSegments(IntSet segments)	Invoked when a node loses ownership of the given segments.
default CompletionStage<Long>	NonBlockingStore.size(IntSet segments)	Returns the amount of entries that map to the given segments in the store.

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
CompletionStage<Void>	DelegatingNonBlockingStore.addSegments(IntSet segments)
CompletionStage<Boolean>	DelegatingPersistenceManager.addSegments(IntSet segments)
CompletionStage<Long>	DelegatingNonBlockingStore.approximateSize(IntSet segments)
CompletionStage<Long>	DelegatingPersistenceManager.approximateSize(Predicate<? super StoreConfiguration> predicate, IntSet segments)
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<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)
CompletionStage<Void>	DelegatingNonBlockingStore.removeSegments(IntSet segments)
CompletionStage<Boolean>	DelegatingPersistenceManager.removeSegments(IntSet segments)
CompletionStage<Long>	DelegatingNonBlockingStore.size(IntSet segments)
CompletionStage<Long>	DelegatingPersistenceManager.size(Predicate<? super StoreConfiguration> predicate, 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.server.iteration.list

Methods in org.infinispan.server.iteration.list with parameters of type IntSet

Modifier and Type	Method	Description
Stream<CacheEntry<Object,Object>>	ListStreamSupplier.buildStream(IntSet ignore, Set valuesToFilter, boolean parallel)

Uses of IntSet in org.infinispan.server.iteration.map

Methods in org.infinispan.server.iteration.map with parameters of type IntSet

Modifier and Type	Method	Description
Stream<CacheEntry<Object,Object>>	MapStreamSupplier.buildStream(IntSet ignore, Set keysToFilter, boolean parallel)

Uses of IntSet in org.infinispan.server.resp.commands.cluster

Methods in org.infinispan.server.resp.commands.cluster that return IntSet

Modifier and Type	Method	Description
IntSet	SegmentSlotRelation.segmentToSlots(int segment)

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 with parameters of type IntSet

Modifier and Type	Method	Description
AbstractDelegatingCacheStream<R>	AbstractDelegatingCacheStream.filterKeySegments(IntSet segments)

Uses of IntSet in org.infinispan.util.logging

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

Modifier and Type	Method	Description
final void	Log_$logger.failedToTransferTombstones(Address requestor, IntSet segments, Throwable t)

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

Subclasses with type arguments of type IntSet in org.infinispan.xsite.commands.remote

Modifier and Type	Class	Description
class	IracPutManyRequest	A multi-key cross-site requests.
class	IracTombstoneCheckRequest	A XSiteCacheRequest to check tombstones for IRAC algorithm.

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)

Uses of IntSet in org.infinispan.xsite.irac

Classes in org.infinispan.xsite.irac that implement interfaces with type arguments of type IntSet

Modifier and Type	Class	Description
class	IracResponseCollector	A response collector for an asynchronous cross site requests.

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

Modifier and Type	Method	Description
void	IracResponseCollector.accept(IntSet rspIntSet, Throwable throwable)
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)