Package org.infinispan.persistence

Class PersistenceUtil

java.lang.Object

org.infinispan.persistence.PersistenceUtil

public class PersistenceUtil
extends Object

Since:

6.0

Author:

Mircea Markus

Constructor Summary

Constructors

Constructor	Description
PersistenceUtil()

Method Summary

Modifier and Type	Method	Description
static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V>	convert(MarshallableEntry<K,V> loaded, org.infinispan.container.impl.InternalEntryFactory factory)
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 Path	getLocation(GlobalConfiguration globalConfiguration, String location)
static Path	getQualifiedLocation(GlobalConfiguration globalConfiguration, String location, String cacheName, String qualifier)
static <K,V> MarshallableEntry<K,V>	loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, InvocationContext context, org.infinispan.commons.time.TimeService timeService)	Deprecated. since 9.4 This method references PersistenceManager, which isn't a public class
static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V>	loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, DataContainer.ComputeAction<K,V> action)	Deprecated. since 9.4 This method references PersistenceManager, which isn't a public class
static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V>	loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)	Deprecated. since 9.4 This method references PersistenceManager, which isn't a public class
static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V>	loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)	Deprecated. since 9.4 This method references PersistenceManager, which isn't a public class
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 String	sanitizedCacheName(String cacheName)	Replace unwanted characters from cache names so they can be used as filenames
static <K,V> Set<org.infinispan.container.entries.InternalCacheEntry<K,V>>	toEntrySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter, org.infinispan.container.impl.InternalEntryFactory ief)
static <K,V> Set<K>	toKeySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter)
static <K,V> Set<K>	toKeySet(NonBlockingStore<K,V> nonBlockingStore, IntSet segments, Predicate<? super K> filter)
static void	validateGlobalStateStoreLocation(GlobalConfiguration globalConfiguration, String storeType, org.infinispan.commons.configuration.attributes.Attribute<?>... attributes)

Constructor Detail

PersistenceUtil

public PersistenceUtil()

Method Detail

count

public static <K,V> int count(AdvancedCacheLoader<K,V> acl,
                                    Predicate<? super K> filter)

count

public static int count(SegmentedAdvancedLoadWriteStore<?,?> salws,
                        IntSet segments)

Counts how many entries are present in the segmented store. Only the segments provided will have entries counted.

Parameters:

salws - segmented store containing entries

segments - segments to count entries from

Returns:

count of entries that are in the provided segments

toKeySet

public static <K,V> Set<K> toKeySet(NonBlockingStore<K,V> nonBlockingStore,
                                          IntSet segments,
                                          Predicate<? super K> filter)

toKeySet

public static <K,V> Set<K> toKeySet(AdvancedCacheLoader<K,V> acl,
                                          Predicate<? super K> filter)

toEntrySet

public static <K,V> Set<org.infinispan.container.entries.InternalCacheEntry<K,V>> toEntrySet(AdvancedCacheLoader<K,V> acl,
                                                                                                         Predicate<? super K> filter,
                                                                                                         org.infinispan.container.impl.InternalEntryFactory ief)

loadAndStoreInDataContainer

@Deprecated
public static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
                                                                                                                     org.infinispan.persistence.manager.PersistenceManager persistenceManager,
                                                                                                                     K key,
                                                                                                                     InvocationContext ctx,
                                                                                                                     org.infinispan.commons.time.TimeService timeService,
                                                                                                                     AtomicReference<Boolean> isLoaded)

Deprecated.

since 9.4 This method references PersistenceManager, which isn't a public class

loadAndStoreInDataContainer

@Deprecated
public static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
                                                                                                                     int segment,
                                                                                                                     org.infinispan.persistence.manager.PersistenceManager persistenceManager,
                                                                                                                     K key,
                                                                                                                     InvocationContext ctx,
                                                                                                                     org.infinispan.commons.time.TimeService timeService,
                                                                                                                     AtomicReference<Boolean> isLoaded)

Deprecated.

since 9.4 This method references PersistenceManager, which isn't a public class

loadAndComputeInDataContainer

@Deprecated
public static <K,V> org.infinispan.container.entries.InternalCacheEntry<K,V> loadAndComputeInDataContainer(DataContainer<K,V> dataContainer,
                                                                                                                       int segment,
                                                                                                                       org.infinispan.persistence.manager.PersistenceManager persistenceManager,
                                                                                                                       K key,
                                                                                                                       InvocationContext ctx,
                                                                                                                       org.infinispan.commons.time.TimeService timeService,
                                                                                                                       DataContainer.ComputeAction<K,V> action)

Deprecated.

since 9.4 This method references PersistenceManager, which isn't a public class

loadAndCheckExpiration

@Deprecated
public static <K,V> MarshallableEntry<K,V> loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager,
                                                                              Object key,
                                                                              InvocationContext context,
                                                                              org.infinispan.commons.time.TimeService timeService)

Deprecated.

since 9.4 This method references PersistenceManager, which isn't a public class

convert

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

parallelizePublisher

public 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.

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.

Type Parameters:

R - the returned value

Parameters:

segments - segments to parallelize across

executor - the executor execute parallelized operations on

publisherFunction - function that creates a different publisher for each segment

Returns:

a publisher that

sanitizedCacheName

public static String sanitizedCacheName(String cacheName)

Replace unwanted characters from cache names so they can be used as filenames

getQualifiedLocation

public static Path getQualifiedLocation(GlobalConfiguration globalConfiguration,
                                        String location,
                                        String cacheName,
                                        String qualifier)

getLocation

public static Path getLocation(GlobalConfiguration globalConfiguration,
                               String location)

validateGlobalStateStoreLocation

public static void validateGlobalStateStoreLocation(GlobalConfiguration globalConfiguration,
                                                    String storeType,
                                                    org.infinispan.commons.configuration.attributes.Attribute<?>... attributes)