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

Fields

Modifier and Type	Field and Description
protected AgentInstanceViewFactoryChainContext	agentInstanceContext
protected List<AggregationServiceAggExpressionDesc>	aggregateNodes
protected AggregationService	aggregationService
protected ObjectArrayEventBean	builtinEventProps
protected EventBean[]	eventsPerStream
protected ExprEvaluator	expiryExpression
protected EPStatementHandleCallback	scheduleHandle
protected long	scheduleSlot
protected Set<String>	variableNames
protected ViewUpdatedCollection	viewUpdatedCollection

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

EMPTY_VIEW_ARRAY, parent

Constructor Summary

Constructors

Constructor and Description
ExpressionViewBase(ViewUpdatedCollection viewUpdatedCollection, ExprEvaluator expiryExpression, AggregationServiceFactoryDesc aggregationServiceFactoryDesc, ObjectArrayEventBean builtinEventProps, Set<String> variableNames, AgentInstanceViewFactoryChainContext agentInstanceContext)

Method Summary

Modifier and Type	Method and Description
AggregationService	getAggregationService()
EventType	getEventType() Provides metadata information about the type of object the event collection contains.
abstract String	getViewName()
ViewUpdatedCollection	getViewUpdatedCollection()
abstract void	scheduleCallback() Implemented to check the expiry expression.
void	stop() Stops the underlying resources.
void	stopScheduleAndVar()
void	stopView()
String	toString()
void	update(Object newValue, 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 java.lang.Iterable

forEach, spliterator

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 Set<String> variableNames

agentInstanceContext

protected final AgentInstanceViewFactoryChainContext agentInstanceContext

scheduleSlot

protected final long scheduleSlot

scheduleHandle

protected final EPStatementHandleCallback scheduleHandle

aggregationService

protected final AggregationService aggregationService

aggregateNodes

protected final List<AggregationServiceAggExpressionDesc> aggregateNodes

Constructor Detail

ExpressionViewBase

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

Method Detail

scheduleCallback

public abstract void scheduleCallback()

Implemented to check the expiry expression.

getViewName

public abstract 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 String toString()

Overrides:

toString in class Object

stopView

public void stopView()

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(Object newValue,
                   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()