Package com.espertech.esper.common.internal.epl.index.base

Class MultiIndexEventTable

java.lang.Object
com.espertech.esper.common.internal.epl.index.base.MultiIndexEventTable
All Implemented Interfaces:
EventTable, Iterable<EventBean>
public class MultiIndexEventTable extends Object implements EventTable
An event table for holding multiple tables for use when multiple indexes of the same dataset must be entered into a cache for use in historical data lookup.

Does not allow iteration, adding and removing events. Does allow clearing all tables and asking for filled or empty tables. All tables are expected to be filled and empty at the same time, reflecting multiple indexes on a single set of data.

  • Constructor Details

    • MultiIndexEventTable

      public MultiIndexEventTable(EventTable[] tables, EventTableOrganization organization)
      Ctor.
      Parameters:
      tables - tables to hold
      organization - organization

  • Method Details

    • getTables

      public EventTable[] getTables()
      Returns all tables.
      Returns:
      tables

    • 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

    • getProviderClass

      public Class getProviderClass()
      Specified by:
      getProviderClass in interface EventTable