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.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 DataWindowViewWithPrevious |
EPStatementStartMethodHelperPrevious.findPreviousViewFactory(List<ViewFactory> factories) |
static PriorEventViewFactory |
EPStatementStartMethodHelperPrior.findPriorViewFactory(List<ViewFactory> factories) |
static void |
EPStatementStartMethodHelperValidate.validateNoDataWindowOnNamedWindow(List<ViewFactory> viewFactories) |
Modifier and Type | Class and Description |
---|---|
class |
VirtualDWViewFactoryImpl |
Modifier and Type | Method and Description |
---|---|
void |
VirtualDWViewFactoryImpl.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualDWViewFactoryImpl.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Class and Description |
---|---|
class |
EventRowRegexNFAViewFactory
View factory for match-recognize view.
|
Modifier and Type | Method and Description |
---|---|
void |
EventRowRegexNFAViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
EventRowRegexNFAViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Interface and Description |
---|---|
interface |
AsymetricDataWindowViewFactory
Marker interface for use with view factories that create data window views
that are asymetric in posting insert and remove stream data:
Data windows that post only a partial insert and remove stream as output when compared to
the insert and remove stream received.
|
interface |
DataWindowViewFactory
Marker interface for use with view factories that create data window views only.
|
Modifier and Type | Class and Description |
---|---|
class |
ViewFactorySupport
Abstract base class for view factories that do not make re-useable views and that do
not share view resources with expression nodes.
|
Modifier and Type | Method and Description |
---|---|
ViewFactory |
ViewResolutionServiceImpl.create(String nameSpace,
String name) |
ViewFactory |
ViewResolutionService.create(String namespace,
String name)
Instantiates a
ViewFactory based on the view namespace and name stored in the view spec. |
ViewFactory |
GroupableView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
List<ViewFactory> |
ViewFactoryChain.getViewFactoryChain()
Returns the chain of view factories.
|
static List<ViewFactory> |
ViewServiceHelper.instantiateFactories(int streamNum,
List<ViewSpec> viewSpecList,
StatementContext statementContext,
boolean isSubquery,
int subqueryNumber)
Given a list of view specifications obtained from by parsing this method instantiates a list of view factories.
|
Modifier and Type | Method and Description |
---|---|
void |
ViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories)
Attaches the factory to a parent event type such that the factory can validate
attach requirements and determine an event type for resulting views.
|
static Object |
ViewFactoryProxy.newInstance(String engineURI,
String statementName,
ViewFactory viewFactory,
String viewName) |
Modifier and Type | Method and Description |
---|---|
void |
ViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories)
Attaches the factory to a parent event type such that the factory can validate
attach requirements and determine an event type for resulting views.
|
ViewServiceCreateResult |
ViewServiceImpl.createViews(Viewable eventStreamViewable,
List<ViewFactory> viewFactories,
AgentInstanceViewFactoryChainContext viewFactoryChainContext,
boolean hasPreviousNode) |
ViewServiceCreateResult |
ViewService.createViews(Viewable eventStreamViewable,
List<ViewFactory> viewFactoryChain,
AgentInstanceViewFactoryChainContext viewFactoryChainContext,
boolean hasPreviousNode)
Creates the views given a chain of view factories.
|
static Set<String> |
ViewServiceHelper.getUniqueCandidateProperties(List<ViewFactory> viewFactory,
Annotation[] annotations) |
static List<View> |
ViewServiceHelper.instantiateChain(Viewable parentViewable,
List<ViewFactory> viewFactories,
AgentInstanceViewFactoryChainContext viewFactoryChainContext)
Instantiate a chain of views.
|
protected static Pair<Viewable,List<View>> |
ViewServiceHelper.matchExistingViews(Viewable rootViewable,
List<ViewFactory> viewFactories,
AgentInstanceContext agentInstanceContext)
Match the views under the stream to the list of view specications passed in.
|
Constructor and Description |
---|
ViewFactoryProxy(String engineURI,
String statementName,
ViewFactory viewFactory,
String viewName) |
Constructor and Description |
---|
ViewFactoryChain(EventType streamEventType,
List<ViewFactory> viewFactoryChain)
Ctor.
|
Modifier and Type | Class and Description |
---|---|
class |
RankWindowViewFactory
Factory for rank window views.
|
class |
SortWindowViewFactory
Factory for sort window views.
|
class |
TimeOrderViewFactory
Factory for views for time-ordering events.
|
class |
TimeToLiveViewFactory
Factory for views for time-ordering events.
|
Modifier and Type | Method and Description |
---|---|
ViewFactory |
TimeOrderView.getViewFactory() |
ViewFactory |
SortWindowView.getViewFactory() |
ViewFactory |
RankWindowView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
void |
TimeToLiveViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeOrderViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
SortWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
RankWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
TimeToLiveViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeOrderViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
SortWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
RankWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Constructor and Description |
---|
TimeOrderView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ViewFactory viewFactory,
ExprNode timestampExpr,
ExprEvaluator timestampEvaluator,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
IStreamSortRankRandomAccess optionalSortedRandomAccess) |
Modifier and Type | Class and Description |
---|---|
class |
IntersectViewFactory
Factory for union-views.
|
class |
NoopViewFactory |
class |
PriorEventViewFactory
Factory for making
PriorEventView instances. |
class |
UnionViewFactory
Factory for union-views.
|
Modifier and Type | Field and Description |
---|---|
protected List<ViewFactory> |
UnionViewFactory.viewFactories
The view factories.
|
protected List<ViewFactory> |
IntersectViewFactory.viewFactories |
Modifier and Type | Method and Description |
---|---|
ViewFactory |
UnionView.getViewFactory() |
ViewFactory |
UnionAsymetricView.getViewFactory() |
ViewFactory |
NoopView.getViewFactory() |
ViewFactory |
IntersectDefaultView.getViewFactory() |
ViewFactory |
IntersectBatchView.getViewFactory() |
ViewFactory |
IntersectAsymetricView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
Collection<ViewFactory> |
ViewFactoryContainer.getViewFactoriesContained() |
Collection<ViewFactory> |
UnionViewFactory.getViewFactoriesContained() |
Collection<ViewFactory> |
IntersectViewFactory.getViewFactoriesContained() |
Modifier and Type | Method and Description |
---|---|
void |
UnionViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
PriorEventViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
NoopViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
IntersectViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
static void |
IntersectDefaultView.visitViewContained(ViewDataVisitorContained viewDataVisitor,
ViewFactory viewFactory,
View[] views) |
Modifier and Type | Method and Description |
---|---|
void |
UnionViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
PriorEventViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
NoopViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
IntersectViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
protected static String |
IntersectViewFactory.getViewNameUnionIntersect(boolean intersect,
Collection<ViewFactory> factories) |
void |
UnionViewFactory.setViewFactories(List<ViewFactory> viewFactories)
Sets the view factories.
|
void |
IntersectViewFactory.setViewFactories(List<ViewFactory> viewFactories)
Sets the view factories.
|
Modifier and Type | Class and Description |
---|---|
class |
CorrelationViewFactory
Factory for
CorrelationView instances. |
class |
RegressionLinestViewFactory
Factory for
RegressionLinestView instances. |
class |
UnivariateStatisticsViewFactory
Factory for
UnivariateStatisticsView instances. |
class |
WeightedAverageViewFactory
Factory for
WeightedAverageView instances. |
Modifier and Type | Field and Description |
---|---|
protected ViewFactory |
BaseBivariateStatisticsView.viewFactory |
Modifier and Type | Method and Description |
---|---|
ViewFactory |
WeightedAverageView.getViewFactory() |
ViewFactory |
UnivariateStatisticsView.getViewFactory() |
ViewFactory |
BaseBivariateStatisticsView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
void |
WeightedAverageViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
UnivariateStatisticsViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
RegressionLinestViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
CorrelationViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
WeightedAverageViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
UnivariateStatisticsViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
RegressionLinestViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
CorrelationViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Constructor and Description |
---|
BaseBivariateStatisticsView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode expressionX,
ExprEvaluator expressionXEval,
ExprNode expressionY,
ExprEvaluator expressionYEval,
EventType eventType,
StatViewAdditionalProps additionalProps)
Constructor requires the name of the two fields to use in the parent view to compute the statistics.
|
CorrelationView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xExpression,
ExprEvaluator xExpressionEval,
ExprNode yExpression,
ExprEvaluator yExpressionEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprEvaluator xEval,
ExprNode yFieldName,
ExprEvaluator yEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
Modifier and Type | Class and Description |
---|---|
class |
FirstElementViewFactory
Factory for
FirstElementView instances. |
class |
FirstUniqueByPropertyViewFactory
Factory for
FirstUniqueByPropertyView instances. |
class |
GroupByViewFactory
Factory for
GroupByView instances. |
class |
LastElementViewFactory
Factory for
LastElementView instances. |
class |
MergeViewFactory
Factory for
MergeView instances. |
class |
SizeViewFactory
Factory for
SizeView instances. |
class |
UniqueByPropertyViewFactory
Factory for
UniqueByPropertyView instances. |
Modifier and Type | Method and Description |
---|---|
ViewFactory |
UniqueByPropertyView.getViewFactory() |
ViewFactory |
LastElementView.getViewFactory() |
ViewFactory |
FirstUniqueByPropertyView.getViewFactory() |
ViewFactory |
FirstElementView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
void |
UniqueByPropertyViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
SizeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
MergeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LastElementViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
GroupByViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstUniqueByPropertyViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstElementViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
UniqueByPropertyViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
SizeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
MergeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LastElementViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
GroupByViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstUniqueByPropertyViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstElementViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
ViewFactory |
TimeWindowView.getViewFactory() |
ViewFactory |
TimeLengthBatchView.getViewFactory() |
ViewFactory |
TimeBatchViewRStream.getViewFactory() |
ViewFactory |
TimeBatchView.getViewFactory() |
ViewFactory |
TimeAccumViewRStream.getViewFactory() |
ViewFactory |
TimeAccumView.getViewFactory() |
ViewFactory |
LengthWindowViewRStream.getViewFactory() |
ViewFactory |
LengthWindowView.getViewFactory() |
ViewFactory |
LengthBatchViewRStream.getViewFactory() |
ViewFactory |
LengthBatchView.getViewFactory() |
ViewFactory |
KeepAllView.getViewFactory() |
ViewFactory |
FirstTimeView.getViewFactory() |
ViewFactory |
FirstLengthWindowView.getViewFactory() |
ViewFactory |
ExternallyTimedWindowView.getViewFactory() |
ViewFactory |
ExternallyTimedBatchView.getViewFactory() |
ViewFactory |
ExpressionWindowView.getViewFactory() |
ViewFactory |
ExpressionBatchView.getViewFactory() |
Modifier and Type | Method and Description |
---|---|
void |
TimeWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeLengthBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeAccumViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LengthWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LengthBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
KeepAllViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstTimeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstLengthWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExternallyTimedWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExternallyTimedBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExpressionViewFactoryBase.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
Modifier and Type | Method and Description |
---|---|
void |
TimeWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeLengthBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
TimeAccumViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LengthWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
LengthBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
KeepAllViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstTimeViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
FirstLengthWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExternallyTimedWindowViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExternallyTimedBatchViewFactory.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |
void |
ExpressionViewFactoryBase.attach(EventType parentEventType,
StatementContext statementContext,
ViewFactory optionalParentFactory,
List<ViewFactory> parentViewFactories) |