public class PersistenceUtil extends Object
Constructor and Description |
---|
PersistenceUtil() |
Modifier and Type | Method and Description |
---|---|
static <K,V> InternalCacheEntry<K,V> |
convert(MarshalledEntry<K,V> loaded,
InternalEntryFactory factory) |
static <K,V> int |
count(AdvancedCacheLoader<K,V> acl,
KeyFilter<? super K> filter)
Deprecated.
Please use
count(AdvancedCacheLoader, Predicate) instead |
static <K,V> int |
count(AdvancedCacheLoader<K,V> acl,
Predicate<? super K> filter) |
static int |
count(SegmentedAdvancedLoadWriteStore<?,?> salws,
IntSet segments)
Counts how many entries are present in the segmented store.
|
static long |
getExpiryTime(InternalMetadata internalMetadata) |
static InternalMetadata |
internalMetadata(InternalCacheEntry ice) |
static InternalMetadata |
internalMetadata(InternalCacheValue icv) |
static <K,V> MarshalledEntry<K,V> |
loadAndCheckExpiration(PersistenceManager persistenceManager,
Object key,
InvocationContext context,
TimeService timeService)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static <K,V> InternalCacheEntry<K,V> |
loadAndComputeInDataContainer(DataContainer<K,V> dataContainer,
int segment,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
DataContainer.ComputeAction<K,V> action)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static <K,V> InternalCacheEntry<K,V> |
loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
int segment,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static <K,V> InternalCacheEntry<K,V> |
loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static KeyFilter |
notNull(KeyFilter filter) |
static <R> org.reactivestreams.Publisher<R> |
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<InternalCacheEntry> |
toEntrySet(AdvancedCacheLoader<K,V> acl,
KeyFilter<? super K> filter,
InternalEntryFactory ief)
Deprecated.
Please use
toEntrySet(AdvancedCacheLoader, Predicate, InternalEntryFactory) instead |
static <K,V> Set<InternalCacheEntry<K,V>> |
toEntrySet(AdvancedCacheLoader<K,V> acl,
Predicate<? super K> filter,
InternalEntryFactory ief) |
static <K,V> Set<K> |
toKeySet(AdvancedCacheLoader<K,V> acl,
KeyFilter<? super K> filter)
Deprecated.
Please use
toKeySet(AdvancedCacheLoader, Predicate) instead |
static <K,V> Set<K> |
toKeySet(AdvancedCacheLoader<K,V> acl,
Predicate<? super K> filter) |
@Deprecated public static <K,V> int count(AdvancedCacheLoader<K,V> acl, KeyFilter<? super K> filter)
count(AdvancedCacheLoader, Predicate)
insteadK
- V
- acl
- filter
- public static <K,V> int count(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter)
public static int count(SegmentedAdvancedLoadWriteStore<?,?> salws, IntSet segments)
salws
- segmented store containing entriessegments
- segments to count entries from@Deprecated public static <K,V> Set<K> toKeySet(AdvancedCacheLoader<K,V> acl, KeyFilter<? super K> filter)
toKeySet(AdvancedCacheLoader, Predicate)
insteadK
- V
- acl
- filter
- public static <K,V> Set<K> toKeySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter)
@Deprecated public static <K,V> Set<InternalCacheEntry> toEntrySet(AdvancedCacheLoader<K,V> acl, KeyFilter<? super K> filter, InternalEntryFactory ief)
toEntrySet(AdvancedCacheLoader, Predicate, InternalEntryFactory)
insteadK
- V
- acl
- filter
- ief
- public static <K,V> Set<InternalCacheEntry<K,V>> toEntrySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter, InternalEntryFactory ief)
public static long getExpiryTime(InternalMetadata internalMetadata)
public static InternalMetadata internalMetadata(InternalCacheEntry ice)
public static InternalMetadata internalMetadata(InternalCacheValue icv)
@Deprecated public static <K,V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
@Deprecated public static <K,V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
@Deprecated public static <K,V> InternalCacheEntry<K,V> loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, DataContainer.ComputeAction<K,V> action)
@Deprecated public static <K,V> MarshalledEntry<K,V> loadAndCheckExpiration(PersistenceManager persistenceManager, Object key, InvocationContext context, TimeService timeService)
public static <K,V> InternalCacheEntry<K,V> convert(MarshalledEntry<K,V> loaded, InternalEntryFactory factory)
public static <R> org.reactivestreams.Publisher<R> parallelizePublisher(IntSet segments, Executor executor, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)
Note that returned publisher will be publishing entries from the invocation of the executor. Thus any subscription will not block the thread it was invoked on, unless explicitly configured to do so.
R
- the returned valuesegments
- segments to parallelize acrossexecutor
- the executor execute parallelized operations onpublisherFunction
- function that creates a different publisher for each segmentCopyright © 2019 JBoss, a division of Red Hat. All rights reserved.