Class GroupManagerImpl
- java.lang.Object
-
- org.infinispan.distribution.group.impl.GroupManagerImpl
-
- All Implemented Interfaces:
GroupManager
public class GroupManagerImpl extends Object implements GroupManager
-
-
Constructor Summary
Constructors Constructor Description GroupManagerImpl(Configuration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <K,V>
Map<K,V>collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)
Collects all entries belonging to a single group.Object
getGroup(Object key)
Get the group for a given key
-
-
-
Constructor Detail
-
GroupManagerImpl
public GroupManagerImpl(Configuration configuration)
-
-
Method Detail
-
getGroup
public Object getGroup(Object key)
Description copied from interface:GroupManager
Get the group for a given key- Specified by:
getGroup
in interfaceGroupManager
- 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 theCacheEntry
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 interfaceGroupManager
- Type Parameters:
K
- The key type.V
- The value type.- Parameters:
stream
- TheCacheStream
ofCacheEntry
to filter.ctx
- TheInvocationContext
to use during its invocation.groupName
- The group name to collect.- Returns:
- A
Map
with keys and value.
-
-