|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.view.ViewSupport
com.espertech.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 com.espertech.esper.view.ViewSupport |
---|
parent |
Constructor Summary | |
---|---|
TimeWindowView(StatementContext statementContext,
TimeWindowViewFactory timeWindowViewFactory,
long millisecondsBeforeExpiry,
ViewUpdatedCollection viewUpdatedCollection,
boolean isRemoveStreamHandling)
Constructor. |
Method Summary | |
---|---|
View |
cloneView(StatementContext statementContext)
Duplicates the view. |
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. |
ViewUpdatedCollection |
getViewUpdatedCollection()
Returns the (optional) collection handling random access to window contents for prior or previous events. |
boolean |
isEmpty()
Returns true if the window is empty, or false if not empty. |
Iterator<EventBean> |
iterator()
Allows iteration through all elements in this event collection. |
String |
toString()
|
void |
update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent. |
Methods inherited from class com.espertech.esper.view.ViewSupport |
---|
addView, dumpChildViews, dumpUpdateParams, dumpUpdateParams, findDescendent, getParent, getViews, hasViews, removeView, setParent, updateChildren, updateChildren |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface com.espertech.esper.view.View |
---|
getParent, setParent |
Methods inherited from interface com.espertech.esper.view.Viewable |
---|
addView, getViews, hasViews, removeView |
Constructor Detail |
---|
public TimeWindowView(StatementContext statementContext, TimeWindowViewFactory timeWindowViewFactory, long millisecondsBeforeExpiry, ViewUpdatedCollection viewUpdatedCollection, boolean isRemoveStreamHandling)
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 eventsstatementContext
- is required view servicestimeWindowViewFactory
- for copying the view in a group-byisRemoveStreamHandling
- flag to indicate that the view must handle the removed events from a parent viewMethod Detail |
---|
public View cloneView(StatementContext statementContext)
CloneableView
Expected to return a same view in initialized state for grouping.
cloneView
in interface CloneableView
statementContext
- is services for the view
public final long getMillisecondsBeforeExpiry()
public ViewUpdatedCollection getViewUpdatedCollection()
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 EventCollection
iterator
in interface Iterable<EventBean>
public final String toString()
toString
in class Object
public boolean isEmpty()
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |