com.espertech.esper.common.internal.view.expression

Class ExpressionViewBase

java.lang.Object

com.espertech.esper.common.internal.view.core.ViewSupport

com.espertech.esper.common.internal.view.expression.ExpressionViewBase

All Implemented Interfaces:

AgentInstanceStopCallback, VariableChangeCallback, DataWindowView, View, Viewable, ViewDataVisitable, Iterable<EventBean>

Direct Known Subclasses:

ExpressionBatchView, ExpressionWindowView

public abstract class ExpressionViewBase
extends ViewSupport
implements DataWindowView, AgentInstanceStopCallback, VariableChangeCallback

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 AgentInstanceContext	agentInstanceContext
protected AggregationService	aggregationService
protected ObjectArrayEventBean	builtinEventProps
protected EventBean[]	eventsPerStream
protected ExpressionViewFactoryBase	factory
protected EPStatementHandleCallbackSchedule	scheduleHandle
protected long	scheduleSlot
protected ViewUpdatedCollection	viewUpdatedCollection

Fields inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

child, parent

Fields inherited from interface com.espertech.esper.common.internal.context.util.AgentInstanceStopCallback

INSTANCE_NO_ACTION

Constructor Summary

Constructors

Constructor and Description
ExpressionViewBase(ExpressionViewFactoryBase factory, ViewUpdatedCollection viewUpdatedCollection, ObjectArrayEventBean builtinEventProps, 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.
ViewFactory	getViewFactory()
ViewUpdatedCollection	getViewUpdatedCollection()
abstract void	scheduleCallback() Implemented to check the expiry expression.
void	stop(AgentInstanceStopServices services)
String	toString()
void	update(Object newValue, Object oldValue) Indicate a change in variable value.

Methods inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

getChild, getParent, setChild, setParent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.espertech.esper.common.internal.view.core.View

getParent, setParent, update

Methods inherited from interface com.espertech.esper.common.internal.view.core.Viewable

getChild, iterator, setChild

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface com.espertech.esper.common.internal.view.core.ViewDataVisitable

visitView

Field Detail

factory

protected final ExpressionViewFactoryBase factory

viewUpdatedCollection

protected final ViewUpdatedCollection viewUpdatedCollection

builtinEventProps

protected final ObjectArrayEventBean builtinEventProps

eventsPerStream

protected final EventBean[] eventsPerStream

agentInstanceContext

protected final AgentInstanceContext agentInstanceContext

scheduleSlot

protected final long scheduleSlot

scheduleHandle

protected final EPStatementHandleCallbackSchedule scheduleHandle

aggregationService

protected final AggregationService aggregationService

Constructor Detail

ExpressionViewBase

public ExpressionViewBase(ExpressionViewFactoryBase factory,
                          ViewUpdatedCollection viewUpdatedCollection,
                          ObjectArrayEventBean builtinEventProps,
                          AgentInstanceViewFactoryChainContext agentInstanceContext)

Method Detail

scheduleCallback

public abstract void scheduleCallback()

Implemented to check the expiry expression.

getEventType

public final EventType getEventType()

Description copied from interface: Viewable

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

Specified by:

getEventType in interface Viewable

Returns:

metadata for the objects in the collection

toString

public final String toString()

Overrides:

toString in class Object

stop

public void stop(AgentInstanceStopServices services)

Specified by:

stop in interface AgentInstanceStopCallback

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()

getViewFactory

public ViewFactory getViewFactory()