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 classesorg.infinispan.distribution Classes relating to the distributed cache mode.org.infinispan.persistence Persistence API.org.infinispan.persistence.jdbc.stringbased JDBC CacheStore implementation which maps keys to strings.org.infinispan.persistence.remote Hot Rod-basedAdvancedLoadWriteStore.org.infinispan.persistence.rocksdb RocksDB-basedAdvancedLoadWriteStore.org.infinispan.persistence.sifs Soft IndexAdvancedLoadWriteStore.org.infinispan.persistence.spi The Persistence SPI. -
-
Uses of IntSet in org.infinispan
Methods in org.infinispan with parameters of type IntSet Modifier and Type Method Description BaseCacheStreamBaseCacheStream. 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 toRemoteCache.entrySet()except that it will only return entries that map to the given segments.CloseableIteratorSet<K>RemoteCache. keySet(IntSet segments)This method is identical toRemoteCache.keySet()except that it will only return keys that map to the given segments.CloseableIteratorCollection<V>RemoteCache. values(IntSet segments)This method is identical toRemoteCache.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 classImmutableIntSetDeprecated.since 9.3 This class will no longer be public, please useIntSets.immutableSet(IntSet)classRangeSetDeprecated.since 9.3 This class will no longer be public.classSmallIntSetDeprecated.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 IntSetIntSets. concurrentCopyFrom(IntSet intSet, int maxExclusive)Returns a copy of the given set that supports concurrent operations.static IntSetIntSets. concurrentSet(int maxExclusive)Returns a concurrent mutable IntSet that can store values in the range of0..maxExclusive-1static IntSetIntSets. from(byte[] bytes)static IntSetIntSets. from(PrimitiveIterator.OfInt iterator)Returns an IntSet based on the ints in the iterator.static IntSetIntSets. from(Set<Integer> integerSet)Returns an IntSet based on the provided Set.IntSetBloomFilter. getIntSet()static IntSetIntSets. immutableEmptySet()Returns an immutable IntSet containing no valuesstatic IntSetIntSets. immutableRangeSet(int endExclusive)Returns an immutable IntSet containing all values from0toendExclusive - 1.static IntSetIntSets. immutableSet(int value)Returns an immutable IntSet containing a single valuestatic IntSetIntSets. immutableSet(IntSet set)Returns an immutable IntSet that wraps the given IntSet to prevent modifications.static IntSetIntSets. mutableCopyFrom(Set<Integer> mutableSet)Returns an IntSet that contains all ints from the given Set that is mutable.static IntSetIntSets. mutableEmptySet()Returns a mutable IntSet with no values set.static IntSetIntSets. mutableEmptySet(int maxExclusive)Returns an IntSet that contains no values but is initialized to hold ints equal to themaxExclusive -1or smaller.static IntSetIntSets. mutableFrom(Set<Integer> integerSet)Returns an IntSet that is mutable that contains all of the values from the given set.static IntSetIntSets. mutableSet(int value)Returns a mutable set with the initial value set.static IntSetIntSets. mutableSet(int value1, int value2)Returns a mutable IntSet that begins with the initialized valuesstatic IntSetIntSetsExternalization. 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 booleanImmutableIntSet. addAll(IntSet set)Deprecated.booleanIntSet. addAll(IntSet set)Adds all ints from the provided set into this onebooleanRangeSet. addAll(IntSet set)Deprecated.booleanSmallIntSet. addAll(IntSet set)Deprecated.static IntSetIntSets. concurrentCopyFrom(IntSet intSet, int maxExclusive)Returns a copy of the given set that supports concurrent operations.booleanImmutableIntSet. containsAll(IntSet set)Deprecated.booleanIntSet. containsAll(IntSet set)Whether this set contains all ints in the given IntSetbooleanRangeSet. containsAll(IntSet set)Deprecated.booleanSmallIntSet. containsAll(IntSet set)Deprecated.static IntSetIntSets. immutableSet(IntSet set)Returns an immutable IntSet that wraps the given IntSet to prevent modifications.booleanIntSet. removeAll(IntSet set)Removes all ints from this IntSet that are in the provided IntSetbooleanRangeSet. removeAll(IntSet set)Deprecated.booleanSmallIntSet. removeAll(IntSet set)Deprecated.booleanIntSet. retainAll(IntSet c)Modifies this set to remove all ints that are not present in the provided IntSetbooleanRangeSet. retainAll(IntSet c)Deprecated.booleanSmallIntSet. retainAll(IntSet c)Deprecated.voidBloomFilter. setBits(IntSet intSet)Clears all current bits and sets them to the values in the providedIntSet.static voidIntSetsExternalization. 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 IntSetLocalizedCacheTopology. getLocalReadSegments() -
Uses of IntSet in org.infinispan.persistence
Methods in org.infinispan.persistence with parameters of type IntSet Modifier and Type Method Description static intPersistenceUtil. 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.jdbc.stringbased
Methods in org.infinispan.persistence.jdbc.stringbased with parameters of type IntSet Modifier and Type Method Description voidJdbcStringBasedStore. clear(IntSet segments)org.reactivestreams.Publisher<MarshallableEntry<K,V>>JdbcStringBasedStore. entryPublisher(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)org.reactivestreams.Publisher<K>JdbcStringBasedStore. publishKeys(IntSet segments, Predicate<? super K> filter)intJdbcStringBasedStore. 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)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)voidTemporaryTable. 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)voidTemporaryTable. 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 voidSegmentedAdvancedLoadWriteStore. 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.voidSegmentedAdvancedLoadWriteStore. 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 voidSegmentedAdvancedLoadWriteStore. 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.intSegmentedAdvancedLoadWriteStore. size(IntSet segments)Deprecated.Returns the number of elements in the store that map to the given segments that aren't expired.
-