|
||||||||||
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.TimeAccumView
public final class TimeAccumView
A data window view that holds events in a stream and only removes events from a stream (rstream) if no more events arrive for a given time interval.
No batch version of the view exists as the batch version is simply the remove stream of this view, which removes in batches.
The view is continuous, the insert stream consists of arriving events. The remove stream only posts current window contents when no more events arrive for a given timer interval.
Field Summary |
---|
Fields inherited from class net.esper.view.ViewSupport |
---|
parent |
Constructor Summary | |
---|---|
TimeAccumView(TimeAccumViewFactory timeBatchViewFactory,
StatementContext statementContext,
long msecIntervalSize,
ViewUpdatedCollection viewUpdatedCollection)
Constructor. |
Method Summary | |
---|---|
View |
cloneView(StatementContext statementContext)
Duplicates the view. |
EventType |
getEventType()
Provides metadata information about the type of object the event collection contains. |
long |
getMsecIntervalSize()
Returns the interval size in milliseconds. |
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. |
protected void |
sendRemoveStream()
This method sends the remove stream for all accumulated events. |
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, 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 TimeAccumView(TimeAccumViewFactory timeBatchViewFactory, StatementContext statementContext, long msecIntervalSize, ViewUpdatedCollection viewUpdatedCollection)
msecIntervalSize
- is the number of milliseconds to batch events forviewUpdatedCollection
- is a collection that the view must update when receiving eventstimeBatchViewFactory
- fr copying this view in a group-bystatementContext
- is required view servicesMethod 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 getMsecIntervalSize()
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 sendRemoveStream()
public boolean isEmpty()
public final Iterator<EventBean> iterator()
EventCollection
iterator
in interface Iterable<EventBean>
iterator
in interface EventCollection
public final String toString()
toString
in class Object
|
© 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 |