com.espertech.esper.epl.join.table

Class SingleReferenceEventTable

java.lang.Object

com.espertech.esper.epl.join.table.SingleReferenceEventTable

All Implemented Interfaces:

EventTable, EventTableAsSet, Iterable<EventBean>

public class SingleReferenceEventTable
extends Object
implements EventTable, EventTableAsSet

Constructor Summary

Constructors

Constructor and Description
SingleReferenceEventTable(EventTableOrganization organization, AtomicReference<ObjectArrayBackedEventBean> eventReference)

Method Summary

Modifier and Type	Method and Description
void	add(EventBean[] events, ExprEvaluatorContext exprEvaluatorContext) Add events to table.
void	add(EventBean event, ExprEvaluatorContext exprEvaluatorContext) Add event to table.
void	addRemove(EventBean[] newData, EventBean[] oldData, ExprEvaluatorContext exprEvaluatorContext) Add and remove events from table.
Set<EventBean>	allValues()
void	clear() Clear out index.
void	destroy() Destroy index.
Object	getIndex() Return the index object itself, or an object-array for multiple index structures.
Integer	getNumberOfEvents() If the number of events is readily available, an implementation will return that number or it may return null to indicate that the count is not readily available.
int	getNumKeys() If the index retains events using some key-based organization this returns the number of keys, and may return -1 to indicate that either the number of keys is not available or costly to obtain.
EventTableOrganization	getOrganization()
Class	getProviderClass()
boolean	isEmpty() Returns true if the index is definitely empty, or false if is not definitely empty but we can not certain.
Iterator<EventBean>	iterator() Returns an iterator over events in the table.
void	remove(EventBean[] events, ExprEvaluatorContext exprEvaluatorContext) Remove events from table.
void	remove(EventBean event, ExprEvaluatorContext exprEvaluatorContext) Remove event from table.
String	toQueryPlan()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SingleReferenceEventTable

public SingleReferenceEventTable(EventTableOrganization organization,
                                 AtomicReference<ObjectArrayBackedEventBean> eventReference)

Method Detail

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)

Description copied from interface: EventTable

Add events to table.

Specified by:

add in interface EventTable

Parameters:

events - to add

exprEvaluatorContext - evaluator context

add

public void add(EventBean event,
                ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: EventTable

Add event to table.

Specified by:

add in interface EventTable

Parameters:

event - to add

exprEvaluatorContext - evaluator context

remove

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

Description copied from interface: EventTable

Remove events from table.

Specified by:

remove in interface EventTable

Parameters:

events - to remove

exprEvaluatorContext - evaluator context

remove

public void remove(EventBean event,
                   ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: EventTable

Remove event from table.

Specified by:

remove in interface EventTable

Parameters:

event - to remove

exprEvaluatorContext - evaluator context

iterator

public Iterator<EventBean> iterator()

Description copied from interface: EventTable

Returns an iterator over events in the table. Not required to be implemented for all indexes. Full table scans and providers that have easy access to an iterator may implement.

Specified by:

iterator in interface EventTable

Specified by:

iterator in interface Iterable<EventBean>

Returns:

table iterator

isEmpty

public boolean isEmpty()

Description copied from interface: EventTable

Returns true if the index is definitely empty, or false if is not definitely empty but we can not certain.

Specified by:

isEmpty in interface EventTable

Returns:

true for definitely empty index, false for there-may-be-rows and please-check-by-iterating

clear

public void clear()

Description copied from interface: EventTable

Clear out index.

Specified by:

clear in interface EventTable

destroy

public void destroy()

Description copied from interface: EventTable

Destroy index.

Specified by:

destroy in interface EventTable

toQueryPlan

public String toQueryPlan()

Specified by:

toQueryPlan in interface EventTable

getNumberOfEvents

public Integer getNumberOfEvents()

Description copied from interface: EventTable

If the number of events is readily available, an implementation will return that number or it may return null to indicate that the count is not readily available.

Specified by:

getNumberOfEvents in interface EventTable

Returns:

number of events

getNumKeys

public int getNumKeys()

Description copied from interface: EventTable

If the index retains events using some key-based organization this returns the number of keys, and may return -1 to indicate that either the number of keys is not available or costly to obtain.

The number returned can be an estimate and may not be accurate.

Specified by:

getNumKeys in interface EventTable

Returns:

number of keys

getIndex

public Object getIndex()

Description copied from interface: EventTable

Return the index object itself, or an object-array for multiple index structures.

May return null if the information is not readily available, i.e. externally maintained index

Specified by:

getIndex in interface EventTable

Returns:

index object

getOrganization

public EventTableOrganization getOrganization()

Specified by:

getOrganization in interface EventTable

allValues

public Set<EventBean> allValues()

Specified by:

allValues in interface EventTableAsSet

getProviderClass

public Class getProviderClass()

Specified by:

getProviderClass in interface EventTable