public class GroupBasedMessageIndexer extends java.lang.Object implements MessageIndexer
| Modifier and Type | Field and Description |
|---|---|
protected TupleMask |
groupMask |
protected java.util.Map<Tuple,DefaultMessageIndexer> |
indexer |
| Constructor and Description |
|---|
GroupBasedMessageIndexer(TupleMask groupMask) |
| Modifier and Type | Method and Description |
|---|---|
void |
clear()
Clear all partial matchings stored in memory
|
void |
delete(Tuple update) |
int |
getCount(Tuple update) |
java.util.Set<Tuple> |
getGroups() |
java.util.Map<Tuple,java.lang.Integer> |
getTuplesByGroup(Tuple group) |
void |
insert(Tuple update) |
boolean |
isEmpty() |
void |
update(Tuple update,
int delta) |
protected final java.util.Map<Tuple,DefaultMessageIndexer> indexer
protected final TupleMask groupMask
public GroupBasedMessageIndexer(TupleMask groupMask)
public int getCount(Tuple update)
getCount in interface MessageIndexerpublic java.util.Set<Tuple> getGroups()
public void insert(Tuple update)
insert in interface MessageIndexerpublic void delete(Tuple update)
delete in interface MessageIndexerpublic void update(Tuple update, int delta)
update in interface MessageIndexerpublic boolean isEmpty()
isEmpty in interface MessageIndexer