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,
ExprNode expressionY,
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,
ExprNode yExpression,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprNode yFieldName,
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) |