|
||||||||||
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.TimeAccumViewRStream
public class TimeAccumViewRStream
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, also handling the remove stream
by keeping set-like semantics. See TimeAccumView
for the same behavior without
remove stream handling.
Field Summary | |
---|---|
protected AgentInstanceViewFactoryChainContext |
agentInstanceContext
|
protected long |
callbackScheduledTime
|
protected java.util.LinkedHashMap<EventBean,java.lang.Long> |
currentBatch
|
protected EPStatementHandleCallback |
handle
|
protected EventBean |
lastEvent
|
protected long |
msecIntervalSize
|
protected ScheduleSlot |
scheduleSlot
|
Fields inherited from class com.espertech.esper.view.ViewSupport |
---|
EMPTY_VIEW_ARRAY, parent |
Constructor Summary | |
---|---|
TimeAccumViewRStream(TimeAccumViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
long msecIntervalSize)
Constructor. |
Method Summary | |
---|---|
View |
cloneView()
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. |
void |
internalHandleAdded(EventBean eventBean,
long timestamp)
|
void |
internalHandleRemoved(EventBean anOldData)
|
boolean |
isEmpty()
Returns true if the window is empty, or false if not empty. |
java.util.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()
|
java.lang.String |
toString()
|
void |
update(EventBean[] newData,
EventBean[] oldData)
Notify that data has been added or removed from the Viewable parent. |
void |
visitView(ViewDataVisitor viewDataVisitor)
|
Methods inherited from class com.espertech.esper.view.ViewSupport |
---|
addView, addView, dumpChildViews, dumpUpdateParams, dumpUpdateParams, findDescendent, findViewIndex, getParent, getViews, hasViews, removeAllViews, removeView, 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, removeAllViews, removeView |
Field Detail |
---|
protected final AgentInstanceViewFactoryChainContext agentInstanceContext
protected final long msecIntervalSize
protected final ScheduleSlot scheduleSlot
protected java.util.LinkedHashMap<EventBean,java.lang.Long> currentBatch
protected EventBean lastEvent
protected long callbackScheduledTime
protected EPStatementHandleCallback handle
Constructor Detail |
---|
public TimeAccumViewRStream(TimeAccumViewFactory timeBatchViewFactory, AgentInstanceViewFactoryChainContext agentInstanceContext, long msecIntervalSize)
msecIntervalSize
- is the number of milliseconds to batch events fortimeBatchViewFactory
- fr copying this view in a group-byMethod Detail |
---|
public View cloneView()
CloneableView
Expected to return a same view in initialized state for grouping.
cloneView
in interface CloneableView
public final long getMsecIntervalSize()
public final EventType getEventType()
EventCollection
getEventType
in interface EventCollection
public 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 viewpublic void visitView(ViewDataVisitor viewDataVisitor)
visitView
in interface ViewDataVisitable
protected void sendRemoveStream()
public boolean isEmpty()
public final java.util.Iterator<EventBean> iterator()
EventCollection
iterator
in interface EventCollection
iterator
in interface java.lang.Iterable<EventBean>
public final java.lang.String toString()
toString
in class java.lang.Object
public void stopView()
stopView
in interface StoppableView
public void stop()
StopCallback
stop
in interface StopCallback
public void stopSchedule()
public void internalHandleRemoved(EventBean anOldData)
public void internalHandleAdded(EventBean eventBean, long timestamp)
|
© 2006-2014 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 |