public class TimeAccumView extends ViewSupport implements CloneableView, DataWindowView, StoppableView, StopCallback
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.
| Modifier and Type | Field and Description |
|---|---|
protected AgentInstanceViewFactoryChainContext |
agentInstanceContext |
protected long |
callbackScheduledTime |
protected ArrayList<EventBean> |
currentBatch |
protected EPStatementHandleCallback |
handle |
protected long |
scheduleSlot |
protected ExprTimePeriodEvalDeltaConst |
timeDeltaComputation |
protected ViewUpdatedCollection |
viewUpdatedCollection |
EMPTY_VIEW_ARRAY, parent| Constructor and Description |
|---|
TimeAccumView(TimeAccumViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
View |
cloneView()
Duplicates the view.
|
EventType |
getEventType()
Provides metadata information about the type of object the event collection contains.
|
ExprTimePeriodEvalDeltaConst |
getTimeDeltaComputation() |
ViewFactory |
getViewFactory() |
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.
|
void |
stop()
Stops the underlying resources.
|
void |
stopSchedule() |
void |
stopView() |
String |
toString() |
void |
update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent.
|
void |
visitView(ViewDataVisitor viewDataVisitor) |
addView, addView, dumpChildViews, dumpUpdateParams, dumpUpdateParams, findDescendent, findViewIndex, getParent, getViews, hasViews, removeAllViews, removeView, removeView, setParent, updateChildren, updateChildrenclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddView, getViews, hasViews, removeAllViews, removeViewforEach, spliteratorprotected final AgentInstanceViewFactoryChainContext agentInstanceContext
protected final ExprTimePeriodEvalDeltaConst timeDeltaComputation
protected final ViewUpdatedCollection viewUpdatedCollection
protected final long scheduleSlot
protected long callbackScheduledTime
protected EPStatementHandleCallback handle
public TimeAccumView(TimeAccumViewFactory timeBatchViewFactory, AgentInstanceViewFactoryChainContext agentInstanceContext, ExprTimePeriodEvalDeltaConst timeDeltaComputation, ViewUpdatedCollection viewUpdatedCollection)
viewUpdatedCollection - is a collection that the view must update when receiving eventstimeBatchViewFactory - fr copying this view in a group-byagentInstanceContext - is required view servicestimeDeltaComputation - delta computationpublic View cloneView()
CloneableViewExpected to return a same view in initialized state for grouping.
cloneView in interface CloneableViewpublic ExprTimePeriodEvalDeltaConst getTimeDeltaComputation()
public final EventType getEventType()
EventCollectiongetEventType in interface EventCollectionpublic void update(EventBean[] newData, EventBean[] oldData)
ViewIf the call to update contains new (inserted) data, then the first argument will be a non-empty list and the second will be empty. Similarly, if the call is a notification of deleted data, then the first argument will be empty and the second will be non-empty. Either the newData or oldData will be non-null. This method won't be called with both arguments being null, but either one could be null. The same is true for zero-length arrays. Either newData or oldData will be non-empty. If both are non-empty, then the update is a modification notification.
When update() is called on a view by the parent object, the data in newData will be in the collection of the parent, and its data structures will be arranged to reflect that. The data in oldData will not be in the parent's data structures, and any access to the parent will indicate that that data is no longer there.
protected void sendRemoveStream()
public boolean isEmpty()
public final Iterator<EventBean> iterator()
EventCollectioniterator in interface EventCollectioniterator in interface Iterable<EventBean>public void stopView()
public void stop()
StopCallbackstop in interface StopCallbackpublic void stopSchedule()
public void visitView(ViewDataVisitor viewDataVisitor)
visitView in interface ViewDataVisitablepublic ViewFactory getViewFactory()
getViewFactory in interface GroupableView