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 Details

    • PersistenceUtil

      public PersistenceUtil()

  • Method Details

    • 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<InternalCacheEntry<K,V>> toEntrySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter, InternalEntryFactory ief)

    • loadAndStoreInDataContainer

      @Deprecated(forRemoval=true) public static <K, V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 9.4 This method references PersistenceManager, which isn't a public class

    • loadAndStoreInDataContainer

      @Deprecated(forRemoval=true) public static <K, V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 9.4 This method references PersistenceManager, which isn't a public class

    • loadAndComputeInDataContainer

      @Deprecated(forRemoval=true) public static <K, V> InternalCacheEntry<K,V> loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, DataContainer.ComputeAction<K,V> action)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 9.4 This method references PersistenceManager, which isn't a public class

    • loadAndCheckExpiration

      @Deprecated(forRemoval=true) public static <K, V> MarshallableEntry<K,V> loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, InvocationContext context, TimeService timeService)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 9.4 This method references PersistenceManager, which isn't a public class

    • convert

      public static <K, V> InternalCacheEntry<K,V> convert(MarshallableEntry<K,V> loaded, 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, Attribute<?>... attributes)