public class PriorEventBufferMulti extends Object implements ViewUpdatedCollection, RelativeAccessByEventNIndex
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.
| Constructor and Description |
|---|
PriorEventBufferMulti(int[] priorToIndexSet)
Ctor.
|
| Modifier and Type | Method and 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) |
public PriorEventBufferMulti(int[] priorToIndexSet)
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.
public void update(EventBean[] newData, EventBean[] oldData)
ViewUpdatedCollectionupdate in interface ViewUpdatedCollectionnewData - is the insert stream events or null if no dataoldData - is the remove stream events or null if no datapublic void update(EventBean[] newData, EventBean[] oldData, PriorEventBufferChangeCaptureMulti capture)
public EventBean getRelativeToEvent(EventBean theEvent, int priorToIndex)
RelativeAccessByEventNIndexgetRelativeToEvent in interface RelativeAccessByEventNIndextheEvent - is the event to count back frompriorToIndex - is the number of events to go backpublic EventBean getRelativeToEnd(int index)
getRelativeToEnd in interface RelativeAccessByEventNIndexpublic int getWindowToEventCount()
getWindowToEventCount in interface RelativeAccessByEventNIndexpublic Iterator<EventBean> getWindowToEvent()
getWindowToEvent in interface RelativeAccessByEventNIndexpublic Collection<EventBean> getWindowToEventCollReadOnly()
getWindowToEventCollReadOnly in interface RelativeAccessByEventNIndexpublic void destroy()
ViewUpdatedCollectiondestroy in interface ViewUpdatedCollectionpublic RollingEventBuffer getNewEvents()
public int getNumEventsInsertBuf()
getNumEventsInsertBuf in interface ViewUpdatedCollection