com.espertech.esper.epl.join.table

Class PropertyIndexedEventTable

java.lang.Object

com.espertech.esper.epl.join.table.PropertyIndexedEventTable

All Implemented Interfaces:

EventTable, Iterable<EventBean>

Direct Known Subclasses:

PropertyIndexedEventTableUnadorned, PropertyIndexedEventTableUnique

public abstract class PropertyIndexedEventTable
extends Object
implements EventTable

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

Fields

Modifier and Type	Field and Description
protected EventTableOrganization	organization
protected EventPropertyGetter[]	propertyGetters

Constructor Summary

Constructors

Constructor and Description
PropertyIndexedEventTable(EventPropertyGetter[] propertyGetters, EventTableOrganization organization)

Method Summary

Modifier and Type	Method and Description
void	add(EventBean[] events, ExprEvaluatorContext exprEvaluatorContext) Add an array of events.
void	addRemove(EventBean[] newData, EventBean[] oldData, ExprEvaluatorContext exprEvaluatorContext) Add and remove events from table.
protected MultiKeyUntyped	getMultiKey(EventBean theEvent) Determine multikey for index access.
EventTableOrganization	getOrganization()
abstract Set<EventBean>	lookup(Object[] keys)
void	remove(EventBean[] events, ExprEvaluatorContext exprEvaluatorContext) Remove events.
String	toQueryPlan()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.join.table.EventTable

add, clear, destroy, getIndex, getNumberOfEvents, getNumKeys, getProviderClass, isEmpty, iterator, remove

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

propertyGetters

protected final EventPropertyGetter[] propertyGetters

organization

protected final EventTableOrganization organization

Constructor Detail

PropertyIndexedEventTable

public PropertyIndexedEventTable(EventPropertyGetter[] propertyGetters,
                                 EventTableOrganization organization)

Method Detail

lookup

public abstract Set<EventBean> lookup(Object[] keys)

getMultiKey

protected MultiKeyUntyped getMultiKey(EventBean theEvent)

Determine multikey for index access.

Parameters:

theEvent - to get properties from for key

Returns:

multi key

addRemove

public void addRemove(EventBean[] newData,
                      EventBean[] oldData,
                      ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: EventTable

Add and remove events from table.

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.

Specified by:

addRemove in interface EventTable

Parameters:

newData - to add

oldData - to remove

exprEvaluatorContext - evaluator context

add

public void add(EventBean[] events,
                ExprEvaluatorContext exprEvaluatorContext)

Add an array of events. Same event instance is not added twice. Event properties should be immutable. Allow null passed instead of an empty array.

Specified by:

add in interface EventTable

Parameters:

events - to add

exprEvaluatorContext - evaluator context

Throws:

IllegalArgumentException - if the event was already existed in the index

remove

public void remove(EventBean[] events,
                   ExprEvaluatorContext exprEvaluatorContext)

Remove events.

Specified by:

remove in interface EventTable

Parameters:

events - to be removed, can be null instead of an empty array.

exprEvaluatorContext - evaluator context

Throws:

IllegalArgumentException - when the event could not be removed as its not in the index

toQueryPlan

public String toQueryPlan()

Specified by:

toQueryPlan in interface EventTable

getOrganization

public EventTableOrganization getOrganization()

Specified by:

getOrganization in interface EventTable