Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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. |
Modifier and Type | Method and Description |
---|---|
void |
KeyTracker.segmentsFinished(IntSet finishedSegments) |
Modifier and Type | Method and Description |
---|---|
IntSet |
IterationNextResponse.getCompletedSegments() |
Modifier and Type | Method and Description |
---|---|
IterationStartOperation |
OperationsFactory.newIterationStartOperation(String filterConverterFactory,
byte[][] filterParameters,
IntSet segments,
int batchSize,
boolean metadata,
DataFormat dataFormat,
SocketAddress targetAddress) |
Constructor and Description |
---|
IterationNextResponse(short status,
List<Map.Entry<K,E>> entries,
IntSet completedSegments,
boolean hasMore) |
Modifier and Type | Method and Description |
---|---|
default <K,V> CloseableIterator<Map.Entry<K,V>> |
Codec.entryIterator(RemoteCache<K,V> remoteCache,
IntSet segments,
int batchSize)
Creates an entry iterator with the given batch size if applicable.
|
<K,V> CloseableIterator<Map.Entry<K,V>> |
Codec23.entryIterator(RemoteCache<K,V> remoteCache,
IntSet segments,
int batchSize) |
default <K> CloseableIterator<K> |
Codec.keyIterator(RemoteCache<K,?> remoteCache,
OperationsFactory operationsFactory,
IntSet segments,
int batchSize)
Creates a key iterator with the given batch size if applicable.
|
<K> CloseableIterator<K> |
Codec20.keyIterator(RemoteCache<K,?> remoteCache,
OperationsFactory operationsFactory,
IntSet segments,
int batchSize) |
<K> CloseableIterator<K> |
Codec23.keyIterator(RemoteCache<K,?> remoteCache,
OperationsFactory operationsFactory,
IntSet segments,
int batchSize) |
<K> CloseableIterator<K> |
Codec27.keyIterator(RemoteCache<K,?> remoteCache,
OperationsFactory operationsFactory,
IntSet segments,
int batchSize) |
default void |
Codec.writeIteratorStartOperation(io.netty.buffer.ByteBuf buf,
IntSet segments,
String filterConverterFactory,
int batchSize,
boolean metadata,
byte[][] filterParameters) |
void |
Codec23.writeIteratorStartOperation(io.netty.buffer.ByteBuf buf,
IntSet segments,
String filterConverterFactory,
int batchSize,
boolean metadata,
byte[][] filterParameters) |
void |
Codec24.writeIteratorStartOperation(io.netty.buffer.ByteBuf buf,
IntSet segments,
String filterConverterFactory,
int batchSize,
boolean metadata,
byte[][] filterParameters) |
Modifier and Type | Method and Description |
---|---|
ConflictResolutionStartCommand |
CommandsFactory.buildConflictResolutionStartCommand(int topologyId,
IntSet segments) |
ConflictResolutionStartCommand |
CommandsFactoryImpl.buildConflictResolutionStartCommand(int topologyId,
IntSet segments) |
<K,V,R> ReductionPublisherRequestCommand<K> |
CommandsFactory.buildEntryReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
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> ReductionPublisherRequestCommand<K> |
CommandsFactoryImpl.buildEntryReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
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> InitialPublisherCommand<K,I,R> |
CommandsFactory.buildInitialPublisherCommand(String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
<K,I,R> InitialPublisherCommand<K,I,R> |
CommandsFactoryImpl.buildInitialPublisherCommand(String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
IracRequestStateCommand |
CommandsFactory.buildIracRequestStateCommand(IntSet segments) |
IracRequestStateCommand |
CommandsFactoryImpl.buildIracRequestStateCommand(IntSet segments) |
<K,R> ReductionPublisherRequestCommand<K> |
CommandsFactory.buildKeyReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
<K,R> ReductionPublisherRequestCommand<K> |
CommandsFactoryImpl.buildKeyReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
ScatteredStateConfirmRevokedCommand |
CommandsFactory.buildScatteredStateConfirmRevokeCommand(int topologyId,
IntSet segments) |
ScatteredStateConfirmRevokedCommand |
CommandsFactoryImpl.buildScatteredStateConfirmRevokeCommand(int topologyId,
IntSet segments) |
ScatteredStateGetKeysCommand |
CommandsFactory.buildScatteredStateGetKeysCommand(int topologyId,
IntSet segments) |
ScatteredStateGetKeysCommand |
CommandsFactoryImpl.buildScatteredStateGetKeysCommand(int topologyId,
IntSet segments) |
StateTransferCancelCommand |
CommandsFactory.buildStateTransferCancelCommand(int topologyId,
IntSet segments) |
StateTransferCancelCommand |
CommandsFactoryImpl.buildStateTransferCancelCommand(int topologyId,
IntSet segments) |
StateTransferGetTransactionsCommand |
CommandsFactory.buildStateTransferGetTransactionsCommand(int topologyId,
IntSet segments) |
StateTransferGetTransactionsCommand |
CommandsFactoryImpl.buildStateTransferGetTransactionsCommand(int topologyId,
IntSet segments) |
StateTransferStartCommand |
CommandsFactory.buildStateTransferStartCommand(int topologyId,
IntSet segments) |
StateTransferStartCommand |
CommandsFactoryImpl.buildStateTransferStartCommand(int topologyId,
IntSet segments) |
Constructor and Description |
---|
IracRequestStateCommand(ByteString cacheName,
IntSet segments) |
Constructor and Description |
---|
ConflictResolutionStartCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
ScatteredStateConfirmRevokedCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
ScatteredStateGetKeysCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
StateTransferCancelCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
StateTransferGetTransactionsCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
StateTransferStartCommand(ByteString cacheName,
int topologyId,
IntSet segments) |
Modifier and Type | Class and 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. Please use
IntSets.immutableRangeSet(int) instead. |
class |
SmallIntSet
Deprecated.
since 9.3 This class will no longer be public. Please use
IntSets methods such as
IntSets.mutableEmptySet() , IntSets.mutableCopyFrom(Set) |
Modifier and Type | Method and 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.
|
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) |
Modifier and Type | Method and Description |
---|---|
static Set<Class<? extends IntSet>> |
IntSetsExternalization.getTypeClasses() |
Modifier and Type | Method and 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) |
Constructor and Description |
---|
ImmutableIntSet(IntSet set)
Deprecated.
|
Modifier and Type | Method and 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) |
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) |
Modifier and Type | Method and Description |
---|---|
IntSet |
LocalizedCacheTopology.getLocalReadSegments() |
Modifier and Type | Field and Description |
---|---|
protected IntSet |
ReadOnlySegmentAwareCollection.allowedSegments |
protected IntSet |
ReadOnlySegmentAwareIterator.allowedSegments |
protected IntSet |
ReadOnlySegmentAwareMap.allowedSegments |
Constructor and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
default CompletionStage<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.
|
CompletionStage<Boolean> |
PersistenceManagerImpl.addSegments(IntSet segments) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PassivationPersistenceManager.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<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<MarshallableEntry<K,V>> |
PersistenceManagerImpl.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManagerStub.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PassivationPersistenceManager.publishKeys(IntSet segments,
Predicate<? super K> filter,
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 CompletionStage<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.
|
CompletionStage<Boolean> |
PersistenceManagerImpl.removeSegments(IntSet segments) |
CompletionStage<Long> |
PersistenceManager.size(IntSet segments)
Returns the count of how many entries are persisted within the given segments.
|
CompletionStage<Long> |
PersistenceManagerImpl.size(IntSet segments) |
CompletionStage<Long> |
PersistenceManagerStub.size(IntSet segments) |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
void |
ComposedSegmentedLoadWriteStore.addSegments(IntSet segments) |
CompletionStage<Void> |
DelegatingNonBlockingStore.addSegments(IntSet segments) |
CompletionStage<Boolean> |
DelegatingPersistenceManager.addSegments(IntSet segments) |
CompletionStage<Void> |
NonBlockingStoreAdapter.addSegments(IntSet segments) |
CompletionStage<Long> |
DelegatingNonBlockingStore.approximateSize(IntSet segments) |
CompletionStage<Long> |
NonBlockingStoreAdapter.approximateSize(IntSet segments) |
void |
ComposedSegmentedLoadWriteStore.clear(IntSet segments) |
org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
ComposedSegmentedLoadWriteStore.entryPublisher(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata) |
org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
DelegatingNonBlockingStore.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean includeValues) |
org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
NonBlockingStoreAdapter.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> |
ComposedSegmentedLoadWriteStore.publishKeys(IntSet segments,
Predicate<? super K> filter) |
org.reactivestreams.Publisher<K> |
DelegatingNonBlockingStore.publishKeys(IntSet segments,
Predicate<? super K> filter) |
org.reactivestreams.Publisher<K> |
NonBlockingStoreAdapter.publishKeys(IntSet segments,
Predicate<? super K> filter) |
<K> org.reactivestreams.Publisher<K> |
DelegatingPersistenceManager.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
void |
ComposedSegmentedLoadWriteStore.removeSegments(IntSet segments) |
CompletionStage<Void> |
DelegatingNonBlockingStore.removeSegments(IntSet segments) |
CompletionStage<Boolean> |
DelegatingPersistenceManager.removeSegments(IntSet segments) |
CompletionStage<Void> |
NonBlockingStoreAdapter.removeSegments(IntSet segments) |
int |
ComposedSegmentedLoadWriteStore.size(IntSet segments) |
CompletionStage<Long> |
DelegatingNonBlockingStore.size(IntSet segments) |
CompletionStage<Long> |
DelegatingPersistenceManager.size(IntSet segments) |
CompletionStage<Long> |
NonBlockingStoreAdapter.size(IntSet segments) |
Modifier and Type | Method and Description |
---|---|
<R> SegmentCompletionPublisher<R> |
ClusterPublisherManager.entryPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
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> SegmentCompletionPublisher<R> |
ClusterPublisherManagerImpl.entryPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentCompletionPublisher<R> |
LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentCompletionPublisher<R> |
PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentAwarePublisher<R> |
LocalPublisherManager.entryPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
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> SegmentAwarePublisher<R> |
LocalPublisherManagerImpl.entryPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
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,
boolean includeLoader,
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,
boolean includeLoader,
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,
boolean includeLoader,
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> |
PartitionAwareClusterPublisherManager.entryReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
InvocationContext ctx,
boolean includeLoader,
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<PublisherResult<R>> |
LocalPublisherManager.entryReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
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<PublisherResult<R>> |
LocalPublisherManagerImpl.entryReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> collator,
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,
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> |
NonSegmentedLocalPublisherManagerImpl.exactlyOnceParallel(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> transformer,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
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,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
protected <I,R> io.reactivex.rxjava3.core.Flowable<R> |
NonSegmentedLocalPublisherManagerImpl.exactlyOnceSequential(CacheSet<I> set,
Set<K> keysToExclude,
Function<I,K> toKeyFunction,
IntSet segments,
Function<? super org.reactivestreams.Publisher<I>,? extends CompletionStage<R>> transformer,
org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener,
IntSet concurrentSegments) |
<R> SegmentCompletionPublisher<R> |
ClusterPublisherManager.keyPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
Same as
ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, boolean, DeliveryGuarantee, int, Function)
except that the source publisher provided to the transformer is made up of keys only. |
<R> SegmentCompletionPublisher<R> |
ClusterPublisherManagerImpl.keyPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentCompletionPublisher<R> |
LocalClusterPublisherManagerImpl.keyPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentCompletionPublisher<R> |
PartitionAwareClusterPublisherManager.keyPublisher(IntSet segments,
Set<K> keysToInclude,
InvocationContext invocationContext,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentAwarePublisher<R> |
LocalPublisherManager.keyPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
Same as
LocalPublisherManager.entryPublisher(IntSet, Set, Set, boolean, DeliveryGuarantee, Function)
except that the source publisher provided to the transformer is made up of keys only. |
<R> SegmentAwarePublisher<R> |
LocalPublisherManagerImpl.keyPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
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,
boolean includeLoader,
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, boolean, 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,
boolean includeLoader,
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,
boolean includeLoader,
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> |
PartitionAwareClusterPublisherManager.keyReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
InvocationContext ctx,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
<R> CompletionStage<PublisherResult<R>> |
LocalPublisherManager.keyReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
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, boolean, DeliveryGuarantee, Function, Function)
except that the source publisher provided to the transformer is made up of keys only. |
<R> CompletionStage<PublisherResult<R>> |
LocalPublisherManagerImpl.keyReduction(boolean parallelPublisher,
IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> collator,
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) |
Modifier and Type | Method and Description |
---|---|
IntSet |
PublisherResponse.getCompletedSegments() |
IntSet |
PublisherResponse.getLostSegments() |
IntSet |
InitialPublisherCommand.getSegments() |
Modifier and Type | Method and Description |
---|---|
static PublisherResponse |
PublisherResponse.emptyResponse(IntSet completedSegments,
IntSet lostSegments) |
Constructor and Description |
---|
InitialPublisherCommand(ByteString cacheName,
String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
KeyPublisherResponse(Object[] results,
IntSet completedSegments,
IntSet lostSegments,
int size,
boolean complete,
Object[] extraObjects,
int extraSize,
Object[] keys,
int keySize) |
PublisherResponse(Object[] results,
IntSet completedSegments,
IntSet lostSegments,
int size,
boolean complete,
int segmentOffset) |
Modifier and Type | Method and Description |
---|---|
IntSet |
KeyPublisherResult.getSuspectedSegments() |
IntSet |
PublisherResult.getSuspectedSegments() |
IntSet |
SegmentPublisherResult.getSuspectedSegments() |
Constructor and Description |
---|
ReductionPublisherRequestCommand(ByteString cacheName,
boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
Function transformer,
Function finalizer) |
SegmentPublisherResult(IntSet suspectedSegments,
R result) |
Modifier and Type | Method and Description |
---|---|
void |
BiasManager.revokeLocalBiasForSegments(IntSet segments)
Stop reading local data from this segment.
|
void |
ScatteredVersionManager.setOwnedSegments(IntSet segments)
Move the segment from
ScatteredVersionManager.SegmentState.NOT_OWNED to ScatteredVersionManager.SegmentState.OWNED without transferring data. |
void |
ScatteredStateProvider.startKeysTransfer(IntSet segments,
Address origin)
Start transferring keys and remote metadata for the given segments to the origin.
|
void |
ScatteredVersionManager.startKeyTransfer(IntSet segments)
Move the segments from
ScatteredVersionManager.SegmentState.BLOCKED to ScatteredVersionManager.SegmentState.KEY_TRANSFER state. |
Modifier and Type | Field and Description |
---|---|
protected IntSet |
ScatteredStateConsumerImpl.inboundSegments |
Modifier and Type | Method and Description |
---|---|
protected CompletionStage<Void> |
ScatteredStateConsumerImpl.handleSegments(boolean startRebalance,
IntSet addedSegments,
IntSet removedSegments) |
protected CompletionStage<Void> |
ScatteredStateConsumerImpl.removeStaleData(IntSet removedSegments) |
void |
BiasManagerImpl.revokeLocalBiasForSegments(IntSet segments) |
void |
ScatteredVersionManagerImpl.setOwnedSegments(IntSet segments) |
void |
ScatteredStateProviderImpl.startKeysTransfer(IntSet segments,
Address origin) |
void |
ScatteredVersionManagerImpl.startKeyTransfer(IntSet segments) |
Modifier and Type | Method and Description |
---|---|
protected IntSet |
StateConsumerImpl.getOwnedSegments(ConsistentHash consistentHash) |
IntSet |
InboundTransferTask.getSegments()
Returns a copy of segments currently tied to this task
|
IntSet |
OutboundTransferTask.getSegments() |
IntSet |
InboundTransferTask.getUnfinishedSegments() |
Modifier and Type | Method and 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.
|
protected void |
StateConsumerImpl.cancelTransfers(IntSet removedSegments)
Cancel transfers for segments we no longer own.
|
CompletionStage<List<TransactionInfo>> |
StateProvider.getTransactionsForSegments(Address destination,
int topologyId,
IntSet segments)
Gets the list of transactions that affect keys from the given segments.
|
CompletionStage<List<TransactionInfo>> |
StateProviderImpl.getTransactionsForSegments(Address destination,
int requestTopologyId,
IntSet segments) |
protected CompletionStage<Void> |
StateConsumerImpl.handleSegments(boolean startRebalance,
IntSet addedSegments,
IntSet removedSegments) |
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> |
StateProviderImpl.publishDataContainerEntries(IntSet segments) |
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> |
StateProviderImpl.publishStoreEntries(IntSet segments) |
protected CompletionStage<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) |
Constructor and Description |
---|
InboundTransferTask(IntSet segments,
Address source,
int topologyId,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName,
boolean applyState) |
OutboundTransferTask(Address destination,
IntSet segments,
int segmentCount,
int chunkSize,
int topologyId,
KeyPartitioner keyPartitioner,
Consumer<Collection<StateChunk>> onChunkReplicated,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName,
boolean applyState,
boolean pushTransfer) |
Modifier and Type | Field and Description |
---|---|
protected IntSet |
AbstractCacheStream.segmentsToFilter |
Modifier and Type | Method and 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) |
Modifier and Type | Field and Description |
---|---|
protected IntSet |
AbstractLocalCacheStream.segmentsToFilter |
Modifier and Type | Method and Description |
---|---|
S |
AbstractLocalCacheStream.StreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<CacheEntry<K,V>> |
EntryStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<K> |
KeyStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<CacheEntry<K,V>> |
PersistenceEntryStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<K> |
PersistenceKeyStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<CacheEntry<K,V>> |
SegmentedEntryStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
Stream<K> |
SegmentedKeyStreamSupplier.buildStream(IntSet segmentsToFilter,
Set<?> keysToFilter,
boolean parallel) |
LocalCacheStream<R> |
LocalCacheStream.filterKeySegments(IntSet segments) |
LocalDoubleCacheStream |
LocalDoubleCacheStream.filterKeySegments(IntSet segments) |
LocalIntCacheStream |
LocalIntCacheStream.filterKeySegments(IntSet segments) |
LocalLongCacheStream |
LocalLongCacheStream.filterKeySegments(IntSet segments) |
Modifier and Type | Method and Description |
---|---|
IntSet |
IntSetExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends IntSet>> |
IntSetExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
AbstractDelegatingCacheStream<R> |
AbstractDelegatingCacheStream.filterKeySegments(IntSet segments) |
void |
IntSetExternalizer.writeObject(ObjectOutput output,
IntSet intSet) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultIracManager.requestState(Address origin,
IntSet segments) |
void |
IracManager.requestState(Address origin,
IntSet segments)
Requests the state stored in this instance for the given
segments . |
void |
NoOpIracManager.requestState(Address origin,
IntSet segments) |
void |
DefaultIracManager.sendStateIfNeeded(Address origin,
IntSet segments,
Object key,
Object lockOwner) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.