Package org.infinispan.distribution.group.impl

Class GroupManagerImpl

java.lang.Object
org.infinispan.distribution.group.impl.GroupManagerImpl
All Implemented Interfaces:
GroupManager
public class GroupManagerImpl extends Object implements GroupManager

  • Constructor Details

    • GroupManagerImpl

      public GroupManagerImpl(Configuration configuration)

  • Method Details

    • getGroup

      public Object getGroup(Object key)
      Description copied from interface: GroupManager
      Get the group for a given key
      Specified by:
      getGroup in interface GroupManager
      Parameters:
      key - the key for which to get the group
      Returns:
      the group, or null if no group is defined for the key

    • collect

      public <K, V> Map<K,V> collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)
      Description copied from interface: GroupManager
      Collects all entries belonging to a single group.

      This method receives a CacheStream and it must filter the CacheEntry that belongs to the group.

      If the cache is transactional, the entries must be stored in the InvocationContext (with proper read version if applicable).

      Specified by:
      collect in interface GroupManager
      Type Parameters:
      K - The key type.
      V - The value type.
      Parameters:
      stream - The CacheStream of CacheEntry to filter.
      ctx - The InvocationContext to use during its invocation.
      groupName - The group name to collect.
      Returns:
      A Map with keys and value.