Package org.infinispan.persistence.internal

Class PersistenceUtil

java.lang.Object

org.infinispan.persistence.internal.PersistenceUtil

public class PersistenceUtil
extends Object

Persistence Utility that is useful for internal classes. Normally methods that require non public classes, such as PersistenceManager, should go in here.

Since:

9.4

Author:

William Burns

Constructor Summary

Constructors

Constructor	Description
PersistenceUtil()

Method Summary

Modifier and Type	Method	Description
static <K> Predicate<? super K>	combinePredicate(IntSet segments, KeyPartitioner keyPartitioner, Predicate<? super K> filter)
static <K,V> InternalCacheEntry<K,V>	convert(MarshalledEntry<K,V> loaded, org.infinispan.container.impl.InternalEntryFactory factory)
static <K,V> MarshalledEntry<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.Flowable<R>	parallelizePublisher(IntSet segments, io.reactivex.Scheduler scheduler, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistenceUtil

public PersistenceUtil()

Method Detail

loadAndStoreInDataContainer

public static <K,V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
                                                                                    PersistenceManager persistenceManager,
                                                                                    K key,
                                                                                    InvocationContext ctx,
                                                                                    TimeService timeService,
                                                                                    AtomicReference<Boolean> isLoaded)

loadAndStoreInDataContainer

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)

loadAndComputeInDataContainer

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)

loadAndCheckExpiration

public static <K,V> MarshalledEntry<K,V> loadAndCheckExpiration(PersistenceManager persistenceManager,
                                                                            Object key,
                                                                            int segment,
                                                                            InvocationContext context)

convert

public static <K,V> InternalCacheEntry<K,V> convert(MarshalledEntry<K,V> loaded,
                                                                org.infinispan.container.impl.InternalEntryFactory factory)

combinePredicate

public static <K> Predicate<? super K> combinePredicate(IntSet segments,
                                                        KeyPartitioner keyPartitioner,
                                                        Predicate<? super K> filter)

parallelizePublisher

public static <R> io.reactivex.Flowable<R> parallelizePublisher(IntSet segments,
                                                                io.reactivex.Scheduler scheduler,
                                                                IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)