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.commons.util	Commons package providing various utility classes
org.infinispan.container.offheap
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.util
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.internal
org.infinispan.persistence.jdbc.stringbased	JDBC CacheStore implementation which maps keys to strings.
org.infinispan.persistence.manager	Implementations of the PersistenceManager interface, which define the logic of how infinispan interacts with external stores.
org.infinispan.persistence.remote	Hot Rod-based AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.support
org.infinispan.scattered	SCATTERED CACHE DESIGN
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.transaction.xa.recovery
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.rxjava

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.

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

Methods in org.infinispan.distribution that return IntSet

Modifier and Type	Method	Description
IntSet	LocalizedCacheTopology.getLocalReadSegments()

Uses of IntSet in org.infinispan.distribution.util

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

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

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

Constructor	Description
ReadOnlySegmentAwareCollection(Collection<E> set, ConsistentHash ch, IntSet allowedSegments)
ReadOnlySegmentAwareEntryCollection(Set<Map.Entry<K,V>> set, ConsistentHash ch, IntSet allowedSegments)
ReadOnlySegmentAwareEntryIterator(Iterator<Map.Entry<K,V>> iter, ConsistentHash ch, IntSet allowedSegments)
ReadOnlySegmentAwareIterator(Iterator<E> iter, ConsistentHash ch, IntSet allowedSegments)
ReadOnlySegmentAwareMap(Map<K,V> map, ConsistentHash ch, 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.

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.Flowable<R>	PersistenceUtil.parallelizePublisher(IntSet segments, io.reactivex.Scheduler scheduler, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)

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
void	JdbcStringBasedStore.clear(IntSet segments)
org.reactivestreams.Publisher<MarshalledEntry<K,V>>	JdbcStringBasedStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
org.reactivestreams.Publisher<K>	JdbcStringBasedStore.publishKeys(IntSet segments, Predicate<? super K> filter)
int	JdbcStringBasedStore.size(IntSet segments)

Uses of IntSet in org.infinispan.persistence.manager

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

Modifier and Type	Method	Description
default boolean	PersistenceManager.addSegments(IntSet segments)	Notifies any underlying segmented stores that the segments provided are owned by this cache and to start/configure any underlying resources required to handle requests for entries on the given segments.
boolean	PersistenceManagerImpl.addSegments(IntSet segments)
<K,V> org.reactivestreams.Publisher<MarshalledEntry<K,V>>	PersistenceManager.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)	Returns a publisher that will publish entries that map to the provided segments.
<K,V> org.reactivestreams.Publisher<MarshalledEntry<K,V>>	PersistenceManagerImpl.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V> org.reactivestreams.Publisher<MarshalledEntry<K,V>>	PersistenceManagerStub.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K> org.reactivestreams.Publisher<K>	PersistenceManager.publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)	Returns a publisher that will publish keys that map to the provided segments.
<K> org.reactivestreams.Publisher<K>	PersistenceManagerImpl.publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
<K> org.reactivestreams.Publisher<K>	PersistenceManagerStub.publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
default boolean	PersistenceManager.removeSegments(IntSet segments)	Notifies any underlying segmented stores that a given segment is no longer owned by this cache and allowing it to remove the given segments and release resources related to it.
boolean	PersistenceManagerImpl.removeSegments(IntSet segments)
int	PersistenceManager.size(IntSet segments)	Returns the count of how many entries are persisted within the given segments.
int	PersistenceManagerImpl.size(IntSet segments)
int	PersistenceManagerStub.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
void	RemoteStore.clear(IntSet segments)
org.reactivestreams.Publisher<MarshalledEntry<K,V>>	RemoteStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
io.reactivex.Flowable<K>	RemoteStore.publishKeys(IntSet segments, Predicate<? super K> filter)
int	RemoteStore.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 void	SegmentedAdvancedLoadWriteStore.addSegments(IntSet segments)	Invoked when a node becomes an owner of the given segments.
void	SegmentedAdvancedLoadWriteStore.clear(IntSet segments)	Removes all the data that maps to the given segments from the storage.
org.reactivestreams.Publisher<MarshalledEntry<K,V>>	SegmentedAdvancedLoadWriteStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)	Publishes all entries from this store.
org.reactivestreams.Publisher<K>	SegmentedAdvancedLoadWriteStore.publishKeys(IntSet segments, Predicate<? super K> filter)	Publishes all the keys that map to the given segments from this store.
default void	SegmentedAdvancedLoadWriteStore.removeSegments(IntSet segments)	Invoked when a node loses ownership of a segment.
int	SegmentedAdvancedLoadWriteStore.size(IntSet segments)	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.support

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

Modifier and Type	Method	Description
void	ComposedSegmentedLoadWriteStore.addSegments(IntSet segments)
void	ComposedSegmentedLoadWriteStore.clear(IntSet segments)
org.reactivestreams.Publisher<MarshalledEntry<K,V>>	ComposedSegmentedLoadWriteStore.publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
io.reactivex.Flowable<K>	ComposedSegmentedLoadWriteStore.publishKeys(IntSet segments, Predicate<? super K> filter)
void	ComposedSegmentedLoadWriteStore.removeSegments(IntSet segments)
int	ComposedSegmentedLoadWriteStore.size(IntSet segments)

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)
void	ScatteredVersionManager.startKeyTransfer(IntSet segments)	Move the segments from ScatteredVersionManager.SegmentState.BLOCKED to ScatteredVersionManager.SegmentState.KEY_TRANSFER state.

Uses of IntSet in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer that return IntSet

Modifier and Type	Method	Description
protected IntSet	StateConsumerImpl.getOwnedSegments(ConsistentHash consistentHash)
IntSet	InboundTransferTask.getSegments()	Returns a copy of segments currently tied to this task
IntSet	OutboundTransferTask.getSegments()
IntSet	StateRequestCommand.getSegments()
IntSet	InboundTransferTask.getUnfinishedSegments()	Returns a copy of the unfinished segments

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

Modifier and Type	Method	Description
protected void	StateConsumerImpl.addTransfer(InboundTransferTask inboundTransfer, IntSet segments)
void	StateConsumerImpl.KeyInvalidationListener.beforeInvalidation(IntSet removedSegments, IntSet staleL1Segments)
void	StateProvider.cancelOutboundTransfer(Address destination, int topologyId, IntSet segments)	Cancel sending of cache entries that belong to the given set of segments.
void	StateProviderImpl.cancelOutboundTransfer(Address destination, int topologyId, IntSet segments)
void	InboundTransferTask.cancelSegments(IntSet cancelledSegments)	Cancels a set of segments and marks them as finished.
void	OutboundTransferTask.cancelSegments(IntSet cancelledSegments)	Cancel some of the segments.
protected void	StateConsumerImpl.cancelTransfers(IntSet removedSegments)	Cancel transfers for segments we no longer own.
List<TransactionInfo>	StateProvider.getTransactionsForSegments(Address destination, int topologyId, IntSet segments)	Gets the list of transactions that affect keys from the given segments.
List<TransactionInfo>	StateProviderImpl.getTransactionsForSegments(Address destination, int requestTopologyId, IntSet segments)
protected void	StateConsumerImpl.handleSegments(boolean startRebalance, IntSet addedSegments, IntSet removedSegments)
protected void	StateConsumerImpl.removeStaleData(IntSet removedSegments)
void	StateProvider.startOutboundTransfer(Address destination, int topologyId, IntSet segments, boolean applyState)	Start to send cache entries that belong to the given set of segments.
void	StateProviderImpl.startOutboundTransfer(Address destination, int requestTopologyId, IntSet segments, boolean applyState)

Constructors in org.infinispan.statetransfer with parameters of type IntSet

Constructor	Description
InboundTransferTask(IntSet segments, Address source, int topologyId, RpcManager rpcManager, org.infinispan.commands.CommandsFactory commandsFactory, long timeout, String cacheName, boolean applyState)
OutboundTransferTask(Address destination, IntSet segments, int segmentCount, int chunkSize, int topologyId, KeyPartitioner keyPartitioner, Consumer<OutboundTransferTask> onCompletion, Consumer<List<StateChunk>> onChunkReplicated, BiFunction<InternalCacheEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer, BiFunction<MarshalledEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromStore, org.infinispan.container.impl.InternalDataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, org.infinispan.commands.CommandsFactory commandsFactory, org.infinispan.container.impl.InternalEntryFactory ef, long timeout, String cacheName, boolean applyState, boolean pushTransfer)
StateRequestCommand(ByteString cacheName, StateRequestCommand.Type type, Address origin, int topologyId, IntSet segments)

Uses of IntSet in org.infinispan.transaction.xa.recovery

Constructors in org.infinispan.transaction.xa.recovery with parameters of type IntSet

Constructor	Description
InDoubtTxInfoImpl(Xid xid, long internalId, IntSet status)

Uses of IntSet in org.infinispan.util

Classes in org.infinispan.util that implement IntSet

Modifier and Type	Class	Description
class	RangeSet	Deprecated. Use RangeSet instead

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

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

Constructor	Description
FlowableFromIntSetFunction(IntSet intSet, IntFunction<T> intFunction)