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

Class IStreamRelativeAccess

java.lang.Object

com.espertech.esper.common.internal.view.previous.IStreamRelativeAccess

All Implemented Interfaces:

ViewUpdatedCollection, RelativeAccessByEventNIndex

public class IStreamRelativeAccess
extends Object
implements RelativeAccessByEventNIndex, ViewUpdatedCollection

Provides relative access to insert stream events for certain window.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	IStreamRelativeAccess.IStreamRelativeAccessUpdateObserver	For indicating that the collection has been updated.

Field Summary

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

EPTYPE

Constructor Summary

Constructors

Constructor	Description
IStreamRelativeAccess(IStreamRelativeAccess.IStreamRelativeAccessUpdateObserver updateObserver)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	destroy()	De-allocate resources held by the collection.
int	getNumEventsInsertBuf()
EventBean	getRelativeToEnd(int prevIndex)
EventBean	getRelativeToEvent(EventBean theEvent, int prevIndex)	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.

Methods inherited from class java.lang.Object

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

Constructor Details

IStreamRelativeAccess

public IStreamRelativeAccess(IStreamRelativeAccess.IStreamRelativeAccessUpdateObserver updateObserver)

Ctor.

Parameters:

updateObserver - is invoked when updates are received

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

getRelativeToEvent

public EventBean getRelativeToEvent(EventBean theEvent,
 int prevIndex)

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

prevIndex - is the number of events to go back

Returns:

event

getRelativeToEnd

public EventBean getRelativeToEnd(int prevIndex)

Specified by:

getRelativeToEnd 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

getWindowToEventCount

public int getWindowToEventCount()

Specified by:

getWindowToEventCount 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

getNumEventsInsertBuf

public int getNumEventsInsertBuf()

Specified by:

getNumEventsInsertBuf in interface ViewUpdatedCollection