|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.join.table.PropertyIndexedEventTable
public class PropertyIndexedEventTable
Index that organizes events by the event property values into hash buckets. Based on a HashMap
with MultiKeyUntyped
keys that store the property values.
Takes a list of property names as parameter. Doesn't care which event type the events have as long as the properties
exist. If the same event is added twice, the class throws an exception on add.
Field Summary | |
---|---|
protected EventPropertyGetter[] |
propertyGetters
|
protected java.util.Map<MultiKeyUntyped,java.util.Set<EventBean>> |
propertyIndex
|
protected int |
streamNum
|
Constructor Summary | |
---|---|
PropertyIndexedEventTable(int streamNum,
EventPropertyGetter[] propertyGetters)
|
Method Summary | |
---|---|
void |
add(EventBean[] events)
Add an array of events. |
void |
addRemove(EventBean[] newData,
EventBean[] oldData)
Add and remove events from table. |
void |
clear()
Clear out index. |
protected MultiKeyUntyped |
getMultiKey(EventBean theEvent)
Determine multikey for index access. |
boolean |
isEmpty()
Returns true if the index is empty, or false if not |
java.util.Iterator<EventBean> |
iterator()
Returns an iterator over events in the table. |
java.util.Set<EventBean> |
lookup(java.lang.Object[] keys)
Returns the set of events that have the same property value as the given event. |
void |
remove(EventBean[] events)
Remove events. |
java.lang.String |
toQueryPlan()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final int streamNum
protected final EventPropertyGetter[] propertyGetters
protected final java.util.Map<MultiKeyUntyped,java.util.Set<EventBean>> propertyIndex
Constructor Detail |
---|
public PropertyIndexedEventTable(int streamNum, EventPropertyGetter[] propertyGetters)
Method Detail |
---|
protected MultiKeyUntyped getMultiKey(EventBean theEvent)
theEvent
- to get properties from for key
public void addRemove(EventBean[] newData, EventBean[] oldData)
EventTable
It is up to the index to decide whether to add first and then remove, or whether to remove and then add.
It is important to note that a given event can be in both the removed and the added events. This means that unique indexes probably need to remove first and then add. Most other non-unique indexes will add first and then remove since the an event can be both in the add and the remove stream.
addRemove
in interface EventTable
newData
- to addoldData
- to removepublic void add(EventBean[] events)
add
in interface EventTable
events
- to add
java.lang.IllegalArgumentException
- if the event was already existed in the indexpublic void remove(EventBean[] events)
remove
in interface EventTable
events
- to be removed, can be null instead of an empty array.
java.lang.IllegalArgumentException
- when the event could not be removed as its not in the indexpublic java.util.Set<EventBean> lookup(java.lang.Object[] keys)
keys
- to compare against
public boolean isEmpty()
EventTable
isEmpty
in interface EventTable
public java.util.Iterator<EventBean> iterator()
EventTable
iterator
in interface EventTable
iterator
in interface java.lang.Iterable<EventBean>
public void clear()
EventTable
clear
in interface EventTable
public java.lang.String toQueryPlan()
toQueryPlan
in interface EventTable
|
© 2006-2011 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |