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 Summary

Constructors

Constructor	Description
GroupManagerImpl(Configuration configuration)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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