Package com.espertech.esper.common.internal.view.prior

Class PriorEventBufferMulti

java.lang.Object

com.espertech.esper.common.internal.view.prior.PriorEventBufferMulti

All Implemented Interfaces:

ViewUpdatedCollection, RelativeAccessByEventNIndex

public class PriorEventBufferMulti
extends Object
implements ViewUpdatedCollection, RelativeAccessByEventNIndex

Buffers view-posted insert stream (new data) and remove stream (old data) events for use with determining prior results in these streams, for multiple different prior events.

Buffers only exactly those events in new data and old data that are being asked for via the 2 or more 'prior' functions that specify different indexes. For example "select prior(2, price), prior(1, price)" results in on buffer instance handling both the need to the immediatly prior (1) and the 2-events-ago event (2).

As all views are required to post new data and post old data that removes the new data to subsequent views, this buffer can be attached to all views and should not result in a memory leak.

When the buffer receives old data (rstream) events it removes the prior events to the rstream events from the buffer the next time it receives a post (not immediatly) to allow queries to the buffer.

Field Summary

Fields inherited from interface com.espertech.esper.common.internal.view.access.RelativeAccessByEventNIndex

EPTYPE

Constructor Summary

Constructors

Constructor	Description
PriorEventBufferMulti(int[] priorToIndexSet)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	destroy()	De-allocate resources held by the collection.
RollingEventBuffer	getNewEvents()
int	getNumEventsInsertBuf()
Map<EventBean,EventBean[]>	getPriorEventMap()
EventBean	getRelativeToEnd(int index)
EventBean	getRelativeToEvent(EventBean theEvent, int priorToIndex)	Returns the prior event to the given event counting back the number of events as supplied by index.
Iterator<EventBean>	getWindowToEvent()
Collection<EventBean>	getWindowToEventCollReadOnly()
int	getWindowToEventCount()
void	update(EventBean[] newData, EventBean[] oldData)	Accepts view insert and remove stream.
void	update(EventBean[] newData, EventBean[] oldData, PriorEventBufferChangeCaptureMulti capture)

Methods inherited from class java.lang.Object

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

Constructor Details

PriorEventBufferMulti

public PriorEventBufferMulti(int[] priorToIndexSet)

Ctor.

Parameters:

priorToIndexSet - holds a list of prior-event indexes.

For example, an array {0,4,6} means the current event, 4 events before the current event and 6 events before the current event.

Method Details

update

public void update(EventBean[] newData,
 EventBean[] oldData)

Description copied from interface: ViewUpdatedCollection

Accepts view insert and remove stream.

Specified by:

update in interface ViewUpdatedCollection

Parameters:

newData - is the insert stream events or null if no data

oldData - is the remove stream events or null if no data

update

public void update(EventBean[] newData,
 EventBean[] oldData,
 PriorEventBufferChangeCaptureMulti capture)

getRelativeToEvent

public EventBean getRelativeToEvent(EventBean theEvent,
 int priorToIndex)

Description copied from interface: RelativeAccessByEventNIndex

Returns the prior event to the given event counting back the number of events as supplied by index.

Specified by:

getRelativeToEvent in interface RelativeAccessByEventNIndex

Parameters:

theEvent - is the event to count back from

priorToIndex - is the number of events to go back

Returns:

event

getRelativeToEnd

public EventBean getRelativeToEnd(int index)

Specified by:

getRelativeToEnd in interface RelativeAccessByEventNIndex

getWindowToEventCount

public int getWindowToEventCount()

Specified by:

getWindowToEventCount in interface RelativeAccessByEventNIndex

getWindowToEvent

public Iterator<EventBean> getWindowToEvent()

Specified by:

getWindowToEvent in interface RelativeAccessByEventNIndex

getWindowToEventCollReadOnly

public Collection<EventBean> getWindowToEventCollReadOnly()

Specified by:

getWindowToEventCollReadOnly in interface RelativeAccessByEventNIndex

destroy

public void destroy()

Description copied from interface: ViewUpdatedCollection

De-allocate resources held by the collection.

Specified by:

destroy in interface ViewUpdatedCollection

getPriorEventMap

public Map<EventBean,EventBean[]> getPriorEventMap()

getNewEvents

public RollingEventBuffer getNewEvents()

getNumEventsInsertBuf

public int getNumEventsInsertBuf()

Specified by:

getNumEventsInsertBuf in interface ViewUpdatedCollection