|
||||||||||
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.TimeLengthBatchView
public final class TimeLengthBatchView
A data view that aggregates events in a stream and releases them in one batch if either one of these conditions is reached, whichever comes first: One, a time interval passes. Two, a given number of events collected.
The view releases the batched events after the interval or number of events as new data to child views. The prior batch if not empty is released as old data to child view. The view DOES release intervals with no old or new data. It does not collect old data published by a parent view. If there are no events in the current and prior batch, the view WILL invoke the update method of child views.
The view starts the first interval when the view is created.
Field Summary |
---|
Fields inherited from class net.esper.view.ViewSupport |
---|
parent |
Constructor Summary | |
---|---|
TimeLengthBatchView(TimeLengthBatchViewFactory timeBatchViewFactory,
StatementContext statementContext,
long msecIntervalSize,
long numberOfEvents,
boolean forceOutput,
boolean isStartEager,
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. |
long |
getNumberOfEvents()
Returns the length of the batch. |
boolean |
isEmpty()
Returns true if the window is empty, or false if not empty. |
boolean |
isForceOutput()
True for force-output. |
boolean |
isStartEager()
True for start-eager. |
Iterator<EventBean> |
iterator()
Allows iteration through all elements in this event collection. |
protected void |
sendBatch(boolean isFromSchedule)
This method updates child views and clears the batch of 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 TimeLengthBatchView(TimeLengthBatchViewFactory timeBatchViewFactory, StatementContext statementContext, long msecIntervalSize, long numberOfEvents, boolean forceOutput, boolean isStartEager, ViewUpdatedCollection viewUpdatedCollection)
msecIntervalSize
- is the number of milliseconds to batch events fornumberOfEvents
- is the event count before the batch fires offviewUpdatedCollection
- is a collection that the view must update when receiving eventstimeBatchViewFactory
- for copying this view in a group-byforceOutput
- is true if the batch should produce empty output if there is no value to output following time intervalsstatementContext
- is required view servicesisStartEager
- is true for start-eagerMethod 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 boolean isForceOutput()
public long getNumberOfEvents()
public boolean isStartEager()
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 sendBatch(boolean isFromSchedule)
isFromSchedule
- true if invoked from a schedule, false if notpublic 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 |