|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.view.ViewSupport
net.esper.view.window.TimeWindowView
public final class TimeWindowView
This view is a moving timeWindow extending the specified amount of milliseconds into the past. The view bases the timeWindow on the time obtained from the scheduling service. All incoming events receive a timestamp and are placed in a sorted map by timestamp. The view does not care about old data published by the parent view to this view. Events leave or expire from the time timeWindow by means of a scheduled callback registered with the scheduling service. Thus child views receive updates containing old data only asynchronously as the system-time-based timeWindow moves on. However child views receive updates containing new data as soon as the new data arrives.
Field Summary |
---|
Fields inherited from class net.esper.view.ViewSupport |
---|
parent |
Constructor Summary | |
---|---|
TimeWindowView()
Default constructor - required by all views to adhere to the Java bean specification. |
|
TimeWindowView(long millisecondsBeforeExpiry,
ViewUpdatedCollection viewUpdatedCollection)
Constructor. |
Method Summary | |
---|---|
protected void |
expire()
This method removes (expires) objects from the window and schedules a new callback for the time when the next oldest message would expire from the window. |
EventType |
getEventType()
Provides metadata information about the type of object the event collection contains. |
long |
getMillisecondsBeforeExpiry()
Returns the size of the time window in millisecond. |
ViewServiceContext |
getViewServiceContext()
Returns the context instances used by the view. |
ViewUpdatedCollection |
getViewUpdatedCollection()
|
boolean |
isEmpty()
|
Iterator<EventBean> |
iterator()
Allows iteration through all elements in this event collection. |
void |
setMillisecondsBeforeExpiry(long millisecondsBeforeExpiry)
Sets the size of the time window in millisecond. |
void |
setViewServiceContext(ViewServiceContext viewServiceContext)
Set the services context containing service handles. |
void |
setViewUpdatedCollection(IStreamRandomAccess viewUpdatedCollection)
|
String |
toString()
|
void |
update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent. |
Methods inherited from class net.esper.view.ViewSupport |
---|
addView, dumpChildViews, dumpUpdateParams, findDescendent, getParent, getViews, hasViews, removeView, setParent, shallowCopyView, updateChildren, updateChildren |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface net.esper.view.View |
---|
getParent, setParent |
Methods inherited from interface net.esper.view.Viewable |
---|
addView, getViews, hasViews, removeView |
Constructor Detail |
---|
public TimeWindowView()
public TimeWindowView(long millisecondsBeforeExpiry, ViewUpdatedCollection viewUpdatedCollection)
millisecondsBeforeExpiry
- is the number of milliseconds before events gets pushed
out of the timeWindow as oldData in the update method.viewUpdatedCollection
- is a collection the view must update when receiving eventsMethod Detail |
---|
public final long getMillisecondsBeforeExpiry()
public final void setMillisecondsBeforeExpiry(long millisecondsBeforeExpiry)
millisecondsBeforeExpiry
- size of windowpublic ViewUpdatedCollection getViewUpdatedCollection()
public void setViewUpdatedCollection(IStreamRandomAccess viewUpdatedCollection)
public final EventType getEventType()
EventCollection
getEventType
in interface EventCollection
public final void update(EventBean[] newData, EventBean[] oldData)
View
update
in interface View
newData
- is the new data that has been added to the parent viewoldData
- is the old data that has been removed from the parent viewprotected final void expire()
public final Iterator<EventBean> iterator()
EventCollection
iterator
in interface Iterable<EventBean>
iterator
in interface EventCollection
public final String toString()
toString
in class Object
public ViewServiceContext getViewServiceContext()
ContextAwareView
getViewServiceContext
in interface ContextAwareView
public void setViewServiceContext(ViewServiceContext viewServiceContext)
ContextAwareView
setViewServiceContext
in interface ContextAwareView
viewServiceContext
- with service handlespublic boolean isEmpty()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |