public class PersistenceUtil extends Object
Constructor and Description |
---|
PersistenceUtil() |
Modifier and Type | Method and Description |
---|---|
static <K> Predicate<? super K> |
combinePredicate(IntSet segments,
KeyPartitioner keyPartitioner,
Predicate<? super K> filter) |
static <K,V> InternalCacheEntry<K,V> |
convert(MarshallableEntry<K,V> loaded,
InternalEntryFactory factory) |
static <T> T |
createStoreInstance(StoreConfiguration config) |
static <K,V> MarshallableEntry<K,V> |
loadAndCheckExpiration(PersistenceManager persistenceManager,
Object key,
int segment,
InvocationContext context) |
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) |
static <K,V> InternalCacheEntry<K,V> |
loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
int segment,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded) |
static <K,V> InternalCacheEntry<K,V> |
loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded) |
static <R> io.reactivex.rxjava3.core.Flowable<R> |
parallelizePublisher(IntSet segments,
io.reactivex.rxjava3.core.Scheduler scheduler,
IntFunction<org.reactivestreams.Publisher<R>> publisherFunction) |
public static <K,V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
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)
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)
public static <K,V> MarshallableEntry<K,V> loadAndCheckExpiration(PersistenceManager persistenceManager, Object key, int segment, InvocationContext context)
public static <K,V> InternalCacheEntry<K,V> convert(MarshallableEntry<K,V> loaded, InternalEntryFactory factory)
public static <K> Predicate<? super K> combinePredicate(IntSet segments, KeyPartitioner keyPartitioner, Predicate<? super K> filter)
public static <R> io.reactivex.rxjava3.core.Flowable<R> parallelizePublisher(IntSet segments, io.reactivex.rxjava3.core.Scheduler scheduler, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)
public static <T> T createStoreInstance(StoreConfiguration config)
Copyright © 2021 JBoss by Red Hat. All rights reserved.