Package | Description |
---|---|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.window |
Window views are in this package
|
Modifier and Type | Method and Description |
---|---|
ViewUpdatedCollection |
AgentInstanceViewFactoryChainContext.getPriorViewUpdatedCollection() |
Constructor and Description |
---|
AgentInstanceViewFactoryChainContext(AgentInstanceContext agentInstanceContext,
boolean isRemoveStream,
Object previousNodeGetter,
ViewUpdatedCollection priorViewUpdatedCollection) |
Modifier and Type | Method and Description |
---|---|
ViewUpdatedCollection |
ViewServicePreviousFactoryImpl.getOptPreviousExprRandomAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
ViewUpdatedCollection |
ViewServicePreviousFactory.getOptPreviousExprRandomAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
ViewUpdatedCollection |
ViewServicePreviousFactoryImpl.getOptPreviousExprRelativeAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
ViewUpdatedCollection |
ViewServicePreviousFactory.getOptPreviousExprRelativeAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
void |
ViewDataVisitor.visitPrimary(ViewUpdatedCollection buffer,
String viewName) |
Modifier and Type | Class and Description |
---|---|
class |
PriorEventBufferMulti
Buffers view-posted insert stream (new data) and remove stream (old data) events for
use with determining prior results in these streams, for multiple different prior events.
|
class |
PriorEventBufferSingle
Buffers view-posted insert stream (new data) and remove stream (old data) events for
use with serving prior results in these streams, for a single prior event.
|
class |
PriorEventBufferUnbound
Buffer class for insert stream events only for use with unbound streams that inserts data only, to serve
up one or more prior events in the insert stream based on an index.
|
Modifier and Type | Field and Description |
---|---|
protected ViewUpdatedCollection |
PriorEventView.buffer |
Modifier and Type | Method and Description |
---|---|
ViewUpdatedCollection |
PriorEventView.getBuffer()
Returns the underlying buffer used for access to prior events.
|
ViewUpdatedCollection |
PriorEventViewFactory.makeViewUpdatedCollection(SortedMap<Integer,List<ExprPriorNode>> callbacksPerIndex,
int agentInstanceId) |
Constructor and Description |
---|
PriorEventView(ViewUpdatedCollection buffer)
Ctor.
|
Modifier and Type | Class and Description |
---|---|
class |
IStreamRandomAccess
For use with length and time window views that must provide random access into data window contents
provided for the "previous" expression if used.
|
class |
IStreamRelativeAccess
Provides relative access to insert stream events for certain window.
|
Modifier and Type | Field and Description |
---|---|
protected ViewUpdatedCollection |
TimeLengthBatchView.viewUpdatedCollection |
protected ViewUpdatedCollection |
TimeBatchView.viewUpdatedCollection |
protected ViewUpdatedCollection |
TimeAccumView.viewUpdatedCollection |
protected ViewUpdatedCollection |
KeepAllView.viewUpdatedCollection |
protected ViewUpdatedCollection |
ExternallyTimedBatchView.viewUpdatedCollection |
protected ViewUpdatedCollection |
ExpressionViewBase.viewUpdatedCollection |
Modifier and Type | Method and Description |
---|---|
ViewUpdatedCollection |
TimeWindowView.getViewUpdatedCollection()
Returns the (optional) collection handling random access to window contents for prior or previous events.
|
ViewUpdatedCollection |
LengthWindowView.getViewUpdatedCollection()
Returns the (optional) collection handling random access to window contents for prior or previous events.
|
ViewUpdatedCollection |
KeepAllView.getViewUpdatedCollection()
Returns the (optional) collection handling random access to window contents for prior or previous events.
|
ViewUpdatedCollection |
ExternallyTimedWindowView.getViewUpdatedCollection() |
ViewUpdatedCollection |
ExpressionViewBase.getViewUpdatedCollection() |
Constructor and Description |
---|
ExpressionBatchView(ExpressionBatchViewFactory dataWindowViewFactory,
ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExpressionViewBase(ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExpressionWindowView(ExpressionWindowViewFactory dataWindowViewFactory,
ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExternallyTimedBatchView(ExternallyTimedBatchViewFactory factory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long optionalReferencePoint,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|
ExternallyTimedWindowView(ExternallyTimedWindowViewFactory externallyTimedWindowViewFactory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|
KeepAllView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
KeepAllViewFactory keepAllViewFactory,
ViewUpdatedCollection viewUpdatedCollection) |
LengthBatchView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthBatchViewFactory lengthBatchViewFactory,
int size,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
LengthWindowView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthWindowViewFactory lengthWindowViewFactory,
int size,
ViewUpdatedCollection viewUpdatedCollection)
Constructor creates a moving window extending the specified number of elements into the past.
|
TimeAccumView(TimeAccumViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
TimeBatchView(TimeBatchViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long referencePoint,
boolean forceOutput,
boolean isStartEager,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
TimeLengthBatchView(TimeLengthBatchViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
long numberOfEvents,
boolean forceOutput,
boolean isStartEager,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
TimeWindowView(AgentInstanceViewFactoryChainContext agentInstanceContext,
TimeWindowViewFactory timeWindowViewFactory,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|