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.commons.util	Commons package providing various utility classes
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.file	Simple filesystem-based CacheWriter implementation.
org.infinispan.persistence.jdbc.common	This package contains a AdvancedLoadWriteStore implementation based on a JDBC database connection.
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.

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.

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.commons.util

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

Modifier and Type	Class	Description
class	ImmutableIntSet	Deprecated. since 9.3 This class will no longer be public, please use IntSets.immutableSet(IntSet)
class	RangeSet	Deprecated. since 9.3 This class will no longer be public.
class	SmallIntSet	Deprecated. 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.
boolean	IntSet.addAll(IntSet set)	Adds all ints from the provided set into this one
boolean	RangeSet.addAll(IntSet set)	Deprecated.
boolean	SmallIntSet.addAll(IntSet set)	Deprecated.
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.
boolean	IntSet.containsAll(IntSet set)	Whether this set contains all ints in the given IntSet
boolean	RangeSet.containsAll(IntSet set)	Deprecated.
boolean	SmallIntSet.containsAll(IntSet set)	Deprecated.
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.
boolean	SmallIntSet.removeAll(IntSet set)	Deprecated.
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.
boolean	SmallIntSet.retainAll(IntSet c)	Deprecated.
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

Constructor	Description
ImmutableIntSet(IntSet set)	Deprecated.

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.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.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.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.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 that return IntSet

Modifier and Type	Method	Description
IntSet	TemporaryTable.getOwnedSegments()

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