Class GroupManagerImpl
java.lang.Object
org.infinispan.distribution.group.impl.GroupManagerImpl
- All Implemented Interfaces:
GroupManager
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescription<K,
V> Map <K, V> collect
(CacheStream<? extends CacheEntry<K, V>> stream, InvocationContext ctx, String groupName) Collects all entries belonging to a single group.Get the group for a given key
-
Constructor Details
-
GroupManagerImpl
-
-
Method Details
-
getGroup
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.
-