Package org.infinispan.distribution.group.impl

Interface GroupManager

All Known Implementing Classes:

GroupManagerImpl

public interface GroupManager

Control's key grouping.

Author:

Pete Muir

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

Method Detail

getGroup

Object getGroup(Object key)

Get the group for a given key

Parameters:

key - the key for which to get the group

Returns:

the group, or null if no group is defined for the key

collect

<K,V> Map<K,V> collect(CacheStream<? extends CacheEntry<K,V>> stream,
                                   InvocationContext ctx,
                                   String groupName)

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

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.