Package | Description |
---|---|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.core.support |
Internal-use-only services for unit and regression testing
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.stat |
Views computing statistical values.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.window |
Window views are in this package
|
Modifier and Type | Method and Description |
---|---|
static AgentInstanceViewFactoryChainContext |
AgentInstanceViewFactoryChainContext.create(List<ViewFactory> viewFactoryChain,
AgentInstanceContext agentInstanceContext,
ViewResourceDelegateVerifiedStream viewResourceDelegate) |
Modifier and Type | Method and Description |
---|---|
static Map<ExprPreviousNode,ExprPreviousEvalStrategy> |
EPStatementStartMethodHelperPrevious.compilePreviousNodeStrategies(ViewResourceDelegateVerified viewResourceDelegate,
AgentInstanceViewFactoryChainContext[] contexts) |
static Map<ExprPriorNode,ExprPriorEvalStrategy> |
EPStatementStartMethodHelperPrior.compilePriorNodeStrategies(ViewResourceDelegateVerified viewResourceDelegate,
AgentInstanceViewFactoryChainContext[] viewFactoryChainContexts) |
Modifier and Type | Method and Description |
---|---|
static AgentInstanceViewFactoryChainContext |
SupportStatementContextFactory.makeAgentInstanceViewFactoryContext() |
static AgentInstanceViewFactoryChainContext |
SupportStatementContextFactory.makeAgentInstanceViewFactoryContext(SchedulingService stub) |
Modifier and Type | Method and Description |
---|---|
View |
VirtualDWViewFactoryImpl.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
View |
EventRowRegexNFAViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Field and Description |
---|---|
protected AgentInstanceViewFactoryChainContext |
TimeOrderView.agentInstanceContext |
protected AgentInstanceViewFactoryChainContext |
SortWindowView.agentInstanceViewFactoryContext |
protected AgentInstanceViewFactoryChainContext |
RankWindowView.agentInstanceViewFactoryContext |
Modifier and Type | Method and Description |
---|---|
View |
TimeToLiveViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
TimeOrderViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
SortWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
RankWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Constructor and Description |
---|
RankWindowView(RankWindowViewFactory rankWindowViewFactory,
int sortWindowSize,
IStreamSortRankRandomAccess optionalRankedRandomAccess,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
SortWindowView(SortWindowViewFactory sortWindowViewFactory,
int sortWindowSize,
IStreamSortRankRandomAccess optionalSortedRandomAccess,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
TimeOrderView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ViewFactory viewFactory,
ExprNode timestampExpr,
ExprEvaluator timestampEvaluator,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
IStreamSortRankRandomAccess optionalSortedRandomAccess) |
Modifier and Type | Field and Description |
---|---|
protected AgentInstanceViewFactoryChainContext |
UnionView.agentInstanceViewFactoryContext |
protected AgentInstanceViewFactoryChainContext |
UnionAsymetricView.agentInstanceViewFactoryContext |
protected AgentInstanceViewFactoryChainContext |
IntersectDefaultView.agentInstanceViewFactoryContext |
protected AgentInstanceViewFactoryChainContext |
IntersectBatchView.agentInstanceViewFactoryContext |
Modifier and Type | Method and Description |
---|---|
View |
UnionViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
PriorEventViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
NoopViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
IntersectViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Constructor and Description |
---|
IntersectAsymetricView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
IntersectViewFactory factory,
List<View> viewList) |
IntersectBatchView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
IntersectViewFactory factory,
List<View> viewList) |
IntersectDefaultView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
IntersectViewFactory factory,
List<View> viewList) |
UnionAsymetricView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
UnionViewFactory factory,
EventType eventType,
List<View> viewList) |
UnionView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
UnionViewFactory factory,
EventType eventType,
List<View> viewList) |
Modifier and Type | Field and Description |
---|---|
protected AgentInstanceViewFactoryChainContext |
UnivariateStatisticsView.agentInstanceContext |
Modifier and Type | Method and Description |
---|---|
View |
WeightedAverageViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
UnivariateStatisticsViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
RegressionLinestViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
CorrelationViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Constructor and Description |
---|
UnivariateStatisticsView(UnivariateStatisticsViewFactory viewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
WeightedAverageView(WeightedAverageViewFactory viewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
Modifier and Type | Field and Description |
---|---|
protected AgentInstanceViewFactoryChainContext |
GroupByViewReclaimAged.agentInstanceContext |
protected AgentInstanceViewFactoryChainContext |
GroupByViewImpl.agentInstanceContext |
protected AgentInstanceViewFactoryChainContext |
UniqueByPropertyView.agentInstanceViewFactoryContext |
protected AgentInstanceViewFactoryChainContext |
FirstUniqueByPropertyView.agentInstanceViewFactoryContext |
Modifier and Type | Method and Description |
---|---|
static Object |
GroupByViewImpl.makeSubViews(GroupByView groupView,
String[] propertyNames,
Object groupByValues,
AgentInstanceViewFactoryChainContext agentInstanceContext)
Instantiate subviews for the given group view and the given key value to group-by.
|
View |
UniqueByPropertyViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
SizeViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
MergeViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
LastElementViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
GroupByViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
FirstUniqueByPropertyViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
FirstElementViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Constructor and Description |
---|
AddPropertyValueOptionalView(AgentInstanceViewFactoryChainContext agentInstanceContext,
String[] propertyNames,
Object mergeValues,
EventType mergedResultEventType)
Constructor.
|
FirstUniqueByPropertyView(FirstUniqueByPropertyViewFactory viewFactory,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
GroupByViewImpl(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators)
Constructor.
|
GroupByViewReclaimAged(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators,
double reclaimMaxAgeSeconds,
double reclaimFrequencySeconds)
Constructor.
|
MergeView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] groupCriteria,
EventType resultEventType,
boolean removable) |
UniqueByPropertyView(UniqueByPropertyViewFactory viewFactory,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
View |
TimeWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
TimeLengthBatchViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
TimeBatchViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
TimeAccumViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
LengthWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
LengthBatchViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
KeepAllViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
FirstTimeViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
FirstLengthWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
ExternallyTimedWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
ExternallyTimedBatchViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
ExpressionWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
ExpressionBatchViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
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.
|
FirstLengthWindowView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
FirstLengthWindowViewFactory lengthFirstWindowViewFactory,
int size) |
FirstTimeView(FirstTimeViewFactory timeFirstViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation)
Constructor.
|
KeepAllView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
KeepAllViewFactory keepAllViewFactory,
ViewUpdatedCollection viewUpdatedCollection) |
LengthBatchView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthBatchViewFactory lengthBatchViewFactory,
int size,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
LengthBatchViewRStream(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthBatchViewFactory lengthBatchViewFactory,
int size)
Constructor.
|
LengthWindowView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthWindowViewFactory lengthWindowViewFactory,
int size,
ViewUpdatedCollection viewUpdatedCollection)
Constructor creates a moving window extending the specified number of elements into the past.
|
LengthWindowViewRStream(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext,
LengthWindowViewFactory lengthWindowViewFactory,
int size)
Constructor creates a moving window extending the specified number of elements into the past.
|
TimeAccumView(TimeAccumViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
TimeAccumViewRStream(TimeAccumViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation)
Constructor.
|
TimeBatchView(TimeBatchViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long referencePoint,
boolean forceOutput,
boolean isStartEager,
ViewUpdatedCollection viewUpdatedCollection)
Constructor.
|
TimeBatchViewRStream(TimeBatchViewFactory timeBatchViewFactory,
AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long referencePoint,
boolean forceOutput,
boolean isStartEager)
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.
|