com.espertech.esper.view.window
Class ExpressionViewBase

java.lang.Object
  com.espertech.esper.view.ViewSupport
      com.espertech.esper.view.window.ExpressionViewBase

All Implemented Interfaces:

VariableChangeCallback, StopCallback, CloneableView, DataWindowView, EventCollection, GroupableView, StoppableView, View, Viewable, ViewDataVisitable, java.lang.Iterable<EventBean>

Direct Known Subclasses:

ExpressionBatchView, ExpressionWindowView

public abstract class ExpressionViewBase
extends ViewSupport
implements DataWindowView, CloneableView, StoppableView, VariableChangeCallback, StopCallback

This view is a moving window extending the into the past until the expression passed to it returns false.

Field Summary

protected AgentInstanceViewFactoryChainContext	agentInstanceContext
protected java.util.List<AggregationServiceAggExpressionDesc>	aggregateNodes
protected AggregationService	aggregationService
protected ObjectArrayEventBean	builtinEventProps
protected EventBean[]	eventsPerStream
protected ExprEvaluator	expiryExpression
protected EPStatementHandleCallback	scheduleHandle
protected ScheduleSlot	scheduleSlot
protected java.util.Set<java.lang.String>	variableNames
protected ViewUpdatedCollection	viewUpdatedCollection

Fields inherited from class com.espertech.esper.view.ViewSupport

EMPTY_VIEW_ARRAY, parent

Constructor Summary

ExpressionViewBase(ViewUpdatedCollection viewUpdatedCollection, ExprEvaluator expiryExpression, AggregationServiceFactoryDesc aggregationServiceFactoryDesc, ObjectArrayEventBean builtinEventProps, java.util.Set<java.lang.String> variableNames, AgentInstanceViewFactoryChainContext agentInstanceContext)

Method Summary

AggregationService	getAggregationService()
EventType	getEventType() Provides metadata information about the type of object the event collection contains.
abstract java.lang.String	getViewName()
ViewUpdatedCollection	getViewUpdatedCollection()
abstract void	scheduleCallback() Implemented to check the expiry expression.
void	stop() Stops the underlying resources.
void	stopScheduleAndVar()
void	stopView()
java.lang.String	toString()
void	update(java.lang.Object newValue, java.lang.Object oldValue) Indicate a change in variable value.

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, update

Methods inherited from interface com.espertech.esper.view.Viewable

addView, getViews, hasViews, removeAllViews, removeView

Methods inherited from interface com.espertech.esper.view.EventCollection

iterator

Methods inherited from interface com.espertech.esper.view.ViewDataVisitable

visitView

Methods inherited from interface com.espertech.esper.view.GroupableView

getViewFactory

Methods inherited from interface com.espertech.esper.view.CloneableView

cloneView

Field Detail

viewUpdatedCollection

protected final ViewUpdatedCollection viewUpdatedCollection

expiryExpression

protected final ExprEvaluator expiryExpression

builtinEventProps

protected final ObjectArrayEventBean builtinEventProps

eventsPerStream

protected final EventBean[] eventsPerStream

variableNames

protected final java.util.Set<java.lang.String> variableNames

agentInstanceContext

protected final AgentInstanceViewFactoryChainContext agentInstanceContext

scheduleSlot

protected final ScheduleSlot scheduleSlot

scheduleHandle

protected final EPStatementHandleCallback scheduleHandle

aggregationService

protected final AggregationService aggregationService

aggregateNodes

protected final java.util.List<AggregationServiceAggExpressionDesc> aggregateNodes

Constructor Detail

ExpressionViewBase

public ExpressionViewBase(ViewUpdatedCollection viewUpdatedCollection,
                          ExprEvaluator expiryExpression,
                          AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
                          ObjectArrayEventBean builtinEventProps,
                          java.util.Set<java.lang.String> variableNames,
                          AgentInstanceViewFactoryChainContext agentInstanceContext)

Method Detail

scheduleCallback

public abstract void scheduleCallback()

Implemented to check the expiry expression.

getViewName

public abstract java.lang.String getViewName()

getEventType

public final EventType getEventType()

Description copied from interface: EventCollection

Provides metadata information about the type of object the event collection contains.

Specified by:

getEventType in interface EventCollection

Returns:

metadata for the objects in the collection

toString

public final java.lang.String toString()

Overrides:

toString in class java.lang.Object

stopView

public void stopView()

Specified by:

stopView in interface StoppableView

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

stopScheduleAndVar

public void stopScheduleAndVar()

update

public void update(java.lang.Object newValue,
                   java.lang.Object oldValue)

Description copied from interface: VariableChangeCallback

Indicate a change in variable value.

Specified by:

update in interface VariableChangeCallback

Parameters:

newValue - new value

oldValue - old value

getViewUpdatedCollection

public ViewUpdatedCollection getViewUpdatedCollection()

getAggregationService

public AggregationService getAggregationService()