com.espertech.esper.epl.join.table

Class PropertyIndexedEventTableFactory

java.lang.Object

com.espertech.esper.epl.join.table.PropertyIndexedEventTableFactory

All Implemented Interfaces:

EventTableFactory

Direct Known Subclasses:

PropertyIndexedEventTableCoerceAddFactory

public class PropertyIndexedEventTableFactory
extends Object
implements EventTableFactory

Index factory 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 String	optionalIndexName
protected EventPropertyGetter[]	propertyGetters Getters for properties.
protected String[]	propertyNames
protected int	streamNum
protected boolean	unique

Constructor Summary

Constructors

Constructor and Description
PropertyIndexedEventTableFactory(int streamNum, EventType eventType, String[] propertyNames, boolean unique, String optionalIndexName) Ctor.

Method Summary

Modifier and Type	Method and Description
Class	getEventTableClass()
String	getOptionalIndexName()
protected EventTableOrganization	getOrganization()
EventPropertyGetter[]	getPropertyGetters()
String[]	getPropertyNames()
int	getStreamNum()
boolean	isUnique()
EventTable[]	makeEventTables(EventTableFactoryTableIdent tableIdent, ExprEvaluatorContext exprEvaluatorContext)
String	toQueryPlan()

Methods inherited from class java.lang.Object

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

Field Detail

streamNum

protected final int streamNum

propertyNames

protected final String[] propertyNames

unique

protected final boolean unique

optionalIndexName

protected final String optionalIndexName

propertyGetters

protected final EventPropertyGetter[] propertyGetters

Getters for properties.

Constructor Detail

PropertyIndexedEventTableFactory

public PropertyIndexedEventTableFactory(int streamNum,
                                        EventType eventType,
                                        String[] propertyNames,
                                        boolean unique,
                                        String optionalIndexName)

Ctor.

Parameters:

streamNum - - the stream number that is indexed

eventType - - types of events indexed

propertyNames - - property names to use for indexing

unique - unique flag

optionalIndexName - index name

Method Detail

makeEventTables

public EventTable[] makeEventTables(EventTableFactoryTableIdent tableIdent,
                                    ExprEvaluatorContext exprEvaluatorContext)

Specified by:

makeEventTables in interface EventTableFactory

getEventTableClass

public Class getEventTableClass()

Specified by:

getEventTableClass in interface EventTableFactory

toQueryPlan

public String toQueryPlan()

Specified by:

toQueryPlan in interface EventTableFactory

getStreamNum

public int getStreamNum()

getPropertyNames

public String[] getPropertyNames()

isUnique

public boolean isUnique()

getOptionalIndexName

public String getOptionalIndexName()

getPropertyGetters

public EventPropertyGetter[] getPropertyGetters()

getOrganization

protected EventTableOrganization getOrganization()