|
||||||||||
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.TimeBatchViewRStream
public class TimeBatchViewRStream
Same as the TimeBatchView
, this view also supports fast-remove from the batch for remove stream events.
Field Summary | |
---|---|
protected AgentInstanceViewFactoryChainContext |
agentInstanceContext
|
protected java.util.LinkedHashSet<EventBean> |
currentBatch
|
protected java.lang.Long |
currentReferencePoint
|
protected EPStatementHandleCallback |
handle
|
protected boolean |
isCallbackScheduled
|
protected java.util.LinkedHashSet<EventBean> |
lastBatch
|
protected long |
msecIntervalSize
|
protected ScheduleSlot |
scheduleSlot
|
Fields inherited from class com.espertech.esper.view.ViewSupport |
---|
EMPTY_VIEW_ARRAY, parent |
Constructor Summary | |
---|---|
TimeBatchViewRStream(TimeBatchViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
long msecIntervalSize,
java.lang.Long referencePoint,
boolean forceOutput,
boolean isStartEager)
Constructor. |
Method Summary | |
---|---|
View |
cloneView()
Duplicates the view. |
EventType |
getEventType()
Provides metadata information about the type of object the event collection contains. |
java.lang.Long |
getInitialReferencePoint()
Gets the reference point to use to anchor interval start and end dates to. |
long |
getMsecIntervalSize()
Returns the interval size in milliseconds. |
void |
internalHandleRemoved(EventBean eventBean)
|
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. |
java.util.Iterator<EventBean> |
iterator()
Allows iteration through all elements in this event collection. |
protected void |
scheduleCallback()
|
protected void |
sendBatch()
This method updates child views and clears the batch of 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. |
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 EPStatementHandleCallback handle
protected java.lang.Long currentReferencePoint
protected java.util.LinkedHashSet<EventBean> lastBatch
protected java.util.LinkedHashSet<EventBean> currentBatch
protected boolean isCallbackScheduled
Constructor Detail |
---|
public TimeBatchViewRStream(TimeBatchViewFactory timeBatchViewFactory, AgentInstanceViewFactoryChainContext agentInstanceContext, long msecIntervalSize, java.lang.Long referencePoint, boolean forceOutput, boolean isStartEager)
msecIntervalSize
- is the number of milliseconds to batch events forreferencePoint
- is the reference point onto which to base intervals, or null if
there is no such reference point suppliedtimeBatchViewFactory
- fr 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 intervalsisStartEager
- is true for start-eagerMethod 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 java.lang.Long getInitialReferencePoint()
public boolean isForceOutput()
public boolean isStartEager()
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 viewprotected void sendBatch()
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
protected void scheduleCallback()
public void stopView()
stopView
in interface StoppableView
public void stop()
StopCallback
stop
in interface StopCallback
public void stopSchedule()
public void internalHandleRemoved(EventBean eventBean)
|
© 2006-2011 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 |