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 MessageIndexer
public java.util.Set<Tuple> getGroups()
public void insert(Tuple update)
insert
in interface MessageIndexer
public void delete(Tuple update)
delete
in interface MessageIndexer
public void update(Tuple update, int delta)
update
in interface MessageIndexer
public boolean isEmpty()
isEmpty
in interface MessageIndexer