Package | Description |
---|---|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.dataflow.ops.epl |
Data flow built-in operator's helper classes.
|
com.espertech.esper.epl.core |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.subquery |
Subquery helper classes are found here.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
com.espertech.esper.epl.variable |
Variable service and variable collections
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
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 |
---|---|
View |
StatementAgentInstanceFactoryOnTriggerTable.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerSplit.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerSetVariable.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerNamedWindow.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
abstract View |
StatementAgentInstanceFactoryOnTriggerBase.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult.getOnExprView() |
Modifier and Type | Method and Description |
---|---|
View |
StatementAgentInstanceFactoryOnTriggerTable.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerSplit.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerSetVariable.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
View |
StatementAgentInstanceFactoryOnTriggerNamedWindow.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
abstract View |
StatementAgentInstanceFactoryOnTriggerBase.determineFinalOutputView(AgentInstanceContext agentInstanceContext,
View onExprView) |
Modifier and Type | Method and Description |
---|---|
protected static void |
StatementAgentInstanceFactorySelect.addViewStopCallback(List<StopCallback> stopCallbacks,
List<View> topViews) |
Constructor and Description |
---|
OnExprViewResult(View onExprView,
AggregationService optionalAggregationService) |
Modifier and Type | Class and Description |
---|---|
class |
ContextMergeView |
class |
ContextMergeViewForwarding |
Modifier and Type | Interface and Description |
---|---|
interface |
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
Modifier and Type | Class and Description |
---|---|
class |
InternalRoutePreprocessView
View for use with pre-processing statement such as "update istream" for indicating previous and current event.
|
class |
UpdateDispatchViewBase
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
class |
UpdateDispatchViewBlockingSpin
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
class |
UpdateDispatchViewBlockingWait
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
class |
UpdateDispatchViewNonBlocking
Convenience view for dispatching view updates received from a parent view to update listeners
via the dispatch service.
|
Modifier and Type | Class and Description |
---|---|
class |
EPLSelectUpdateDispatchView |
class |
EPLSelectViewable |
Modifier and Type | Method and Description |
---|---|
View |
EPLSelectViewable.addView(View view) |
Modifier and Type | Method and Description |
---|---|
View |
EPLSelectViewable.addView(View view) |
Modifier and Type | Method and Description |
---|---|
View |
MethodPollingViewable.addView(View view) |
View[] |
MethodPollingViewable.getViews() |
Modifier and Type | Method and Description |
---|---|
View |
MethodPollingViewable.addView(View view) |
boolean |
MethodPollingViewable.removeView(View view) |
Modifier and Type | Method and Description |
---|---|
View |
DatabasePollingViewable.addView(View view) |
View[] |
DatabasePollingViewable.getViews() |
Modifier and Type | Method and Description |
---|---|
View |
DatabasePollingViewable.addView(View view) |
boolean |
DatabasePollingViewable.removeView(View view) |
Modifier and Type | Class and Description |
---|---|
class |
NamedWindowConsumerView
Represents a consumer of a named window that selects from a named window via a from-clause.
|
class |
NamedWindowOnDeleteView
View for the on-delete statement that handles removing events from a named window.
|
class |
NamedWindowOnExprBaseView
View for the on-delete statement that handles removing events from a named window.
|
class |
NamedWindowOnMergeView
View for the on-delete statement that handles removing events from a named window.
|
class |
NamedWindowOnSelectView
View for the on-select statement that handles selecting events from a named window.
|
class |
NamedWindowOnUpdateView
View for the on-delete statement that handles removing events from a named window.
|
class |
NamedWindowRootViewInstance
The root window in a named window plays multiple roles: It holds the indexes for deleting rows, if any on-delete statement
requires such indexes.
|
class |
NamedWindowTailViewInstance
This view is hooked into a named window's view chain as the last view and handles dispatching of named window
insert and remove stream results via
NamedWindowMgmtService to consuming statements. |
Modifier and Type | Class and Description |
---|---|
class |
SubselectAggregatorViewBase
View handling the insert and remove stream generated by a subselect
for application to aggregation state.
|
class |
SubselectAggregatorViewFilteredGrouped |
class |
SubselectAggregatorViewFilteredUngrouped |
class |
SubselectAggregatorViewUnfilteredGrouped |
class |
SubselectAggregatorViewUnfilteredUngrouped |
Modifier and Type | Class and Description |
---|---|
class |
TableStateViewableInternal |
class |
TableStateViewablePublic |
Modifier and Type | Class and Description |
---|---|
class |
TableOnDeleteView
View for the on-delete statement that handles removing events from a named window.
|
class |
TableOnMergeView |
class |
TableOnSelectView |
class |
TableOnUpdateView |
class |
TableOnViewBase |
Modifier and Type | Class and Description |
---|---|
class |
CreateVariableView
View for handling create-variable syntax.
|
class |
OnSetVariableView
A view that handles the setting of variables upon receipt of a triggering event.
|
Modifier and Type | Class and Description |
---|---|
class |
FilterExprView
Simple filter view filtering events using a filter expression tree.
|
class |
OutputProcessViewBase |
class |
OutputProcessViewBaseCallback
Factory for output processing views.
|
class |
OutputProcessViewBaseWAfter |
class |
OutputProcessViewConditionDefault
A view that prepares output events, batching incoming
events and invoking the result set processor as necessary.
|
class |
OutputProcessViewConditionDefaultPostProcess
A view that prepares output events, batching incoming
events and invoking the result set processor as necessary.
|
class |
OutputProcessViewConditionFirst
Handles output rate limiting for FIRST, only applicable with a having-clause and no group-by clause.
|
class |
OutputProcessViewConditionFirstPostProcess
Handles output rate limiting for FIRST, only applicable with a having-clause and no group-by clause.
|
class |
OutputProcessViewConditionLastAllUnord
Handles output rate limiting for LAST and without order-by.
|
class |
OutputProcessViewConditionLastAllUnordPostProcessAll |
class |
OutputProcessViewConditionSnapshot
A view that handles the "output snapshot" keyword in output rate stabilizing.
|
class |
OutputProcessViewConditionSnapshotPostProcess
A view that handles the "output snapshot" keyword in output rate stabilizing.
|
class |
OutputProcessViewDirect
Output process view that does not enforce any output policies and may simply
hand over events to child views, does not handle distinct.
|
class |
OutputProcessViewDirectDistinctOrAfter
Output process view that does not enforce any output policies and may simply
hand over events to child views, but works with distinct and after-output policies
|
class |
OutputProcessViewDirectDistinctOrAfterPostProcess
Output process view that does not enforce any output policies and may simply
hand over events to child views, but works with distinct and after-output policies
|
class |
OutputProcessViewDirectPostProcess |
Modifier and Type | Method and Description |
---|---|
View |
OutputProcessViewBase.addView(View view) |
View[] |
OutputProcessViewBase.getViews() |
Modifier and Type | Method and Description |
---|---|
View |
OutputProcessViewBase.addView(View view) |
boolean |
OutputProcessViewBase.removeView(View view) |
Modifier and Type | Class and Description |
---|---|
class |
VirtualDWViewImpl |
Modifier and Type | Method and Description |
---|---|
View |
VirtualDWViewFactoryImpl.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
VirtualDWViewFactoryImpl.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qViewIndicate(View view,
String viewName,
EventBean[] newData,
EventBean[] oldData) |
void |
Instrumentation.qViewIndicate(View view,
String viewName,
EventBean[] newData,
EventBean[] oldData) |
void |
InstrumentationDefault.qViewProcessIRStream(View view,
String viewName,
EventBean[] newData,
EventBean[] oldData) |
void |
Instrumentation.qViewProcessIRStream(View view,
String viewName,
EventBean[] newData,
EventBean[] oldData) |
void |
InstrumentationDefault.qViewScheduledEval(View view,
String viewName) |
void |
Instrumentation.qViewScheduledEval(View view,
String viewName) |
Modifier and Type | Class and Description |
---|---|
class |
EventRowRegexNFAView
View for match recognize support.
|
Modifier and Type | Method and Description |
---|---|
View |
EventRowRegexNFAViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
DataWindowView
Tag interface for data window views.
|
interface |
DerivedValueView
Tag interface for derived-value views.
|
Modifier and Type | Class and Description |
---|---|
class |
ViewSupport
A helper class for View implementations that provides generic implementation for some of the methods.
|
Modifier and Type | Field and Description |
---|---|
static View[] |
ViewSupport.EMPTY_VIEW_ARRAY |
Modifier and Type | Method and Description |
---|---|
View |
ZeroDepthStreamNoIterate.addView(View view) |
View |
ZeroDepthStreamIterable.addView(View view) |
View |
ViewSupport.addView(View view) |
View |
ViewableDefaultImpl.addView(View view) |
View |
Viewable.addView(View view)
Add a view to the viewable object.
|
static View[] |
ViewSupport.addView(View[] children,
View view) |
View |
CloneableView.cloneView()
Duplicates the view.
|
View[] |
ZeroDepthStreamNoIterate.getViews() |
View[] |
ZeroDepthStreamIterable.getViews() |
View[] |
ViewSupport.getViews() |
View[] |
ViewableDefaultImpl.getViews() |
View[] |
Viewable.getViews()
Returns all added views.
|
View |
ViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Create a new view.
|
static View[] |
ViewSupport.removeView(View[] children,
int index) |
Modifier and Type | Method and Description |
---|---|
static List<View> |
ViewSupport.findDescendent(Viewable parentView,
Viewable descendentView)
Find the descendent view in the view tree under the parent view returning the list of view nodes
between the parent view and the descendent view.
|
List<View> |
ViewServiceCreateResult.getNewViews() |
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.
|
protected static List<View> |
ViewServiceHelper.removeChainLeafView(Viewable parentViewable,
Viewable viewToRemove)
Removes a view from a parent view returning the orphaned parent views in a list.
|
Modifier and Type | Method and Description |
---|---|
View |
ZeroDepthStreamNoIterate.addView(View view) |
View |
ZeroDepthStreamIterable.addView(View view) |
View |
ViewSupport.addView(View view) |
View |
ViewableDefaultImpl.addView(View view) |
View |
Viewable.addView(View view)
Add a view to the viewable object.
|
static View[] |
ViewSupport.addView(View[] children,
View view) |
static View[] |
ViewSupport.addView(View[] children,
View view) |
boolean |
ViewFactorySupport.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
ViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext)
Determines if the given view could be used instead of creating a new view,
requires the view factory to compare view type, parameters and other capabilities provided.
|
static int |
ViewSupport.findViewIndex(View[] children,
View view) |
static int |
ViewSupport.findViewIndex(View[] children,
View view) |
static Object |
ViewProxy.newInstance(String engineURI,
String statementName,
String viewName,
View view) |
boolean |
ZeroDepthStreamNoIterate.removeView(View view) |
boolean |
ZeroDepthStreamIterable.removeView(View view) |
boolean |
ViewSupport.removeView(View view) |
boolean |
ViewableDefaultImpl.removeView(View view) |
boolean |
Viewable.removeView(View view)
Remove a view.
|
static View[] |
ViewSupport.removeView(View[] children,
int index) |
void |
ViewDataVisitorContained.visitContained(Object containedKey,
View containedView) |
Modifier and Type | Method and Description |
---|---|
static void |
ViewServiceHelper.removeFirstUnsharedView(List<View> childViews) |
protected static void |
ViewSupport.updateChildren(Collection<View> childViews,
EventBean[] newData,
EventBean[] oldData)
Updates all the children with new data.
|
Constructor and Description |
---|
ViewProxy(String engineURI,
String statementName,
String viewName,
View view) |
Constructor and Description |
---|
ViewServiceCreateResult(Viewable finalViewable,
Viewable topViewable,
List<View> newViews) |
Modifier and Type | Class and Description |
---|---|
class |
RankWindowView
Window sorting by values in the specified field extending a specified number of elements
from the lowest value up or the highest value down and retaining only the last unique value per key.
|
class |
SortWindowView
Window sorting by values in the specified field extending a specified number of elements
from the lowest value up or the highest value down.
|
class |
TimeOrderView
Window retaining timestamped events up to a given number of seconds such that
older events that arrive later are sorted into the window and released in timestamp order.
|
Modifier and Type | Method and Description |
---|---|
View |
TimeOrderView.cloneView() |
View |
SortWindowView.cloneView() |
View |
RankWindowView.cloneView() |
View |
TimeToLiveViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
TimeOrderViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
SortWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
RankWindowViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
TimeToLiveViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
TimeOrderViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
SortWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
RankWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Class and Description |
---|---|
class |
BufferView
A view that acts as an adapter between views and update listeners.
|
class |
IntersectAsymetricView
A view that represents an intersection of multiple data windows.
|
class |
IntersectBatchView
A view that represents an intersection of multiple data windows.
|
class |
IntersectDefaultView
A view that represents an intersection of multiple data windows.
|
class |
LastPostObserverView
A view that retains the last update.
|
class |
NoopView |
class |
PatternRemoveDispatchView
View to handle pattern discarding for a single stream (no join).
|
class |
PriorEventView
View that provides access to prior events posted by the parent view for use by 'prior' expression nodes.
|
class |
RouteResultView
View for processing split-stream syntax.
|
class |
SingleStreamDispatchView
View to dispatch for a single stream (no join).
|
class |
UnionAsymetricView
A view that represents a union of multiple data windows wherein at least one is asymetric:
it does not present a insert stream for each insert stream event received.
|
class |
UnionView
A view that represents a union of multiple data windows.
|
Modifier and Type | Field and Description |
---|---|
protected View[] |
UnionView.views |
protected View[] |
UnionAsymetricView.views |
protected View[] |
IntersectDefaultView.views |
protected View[] |
IntersectBatchView.views |
protected View[] |
IntersectAsymetricView.views |
Modifier and Type | Method and Description |
---|---|
View |
LastPostObserverView.addView(View view) |
View |
UnionView.cloneView() |
View |
UnionAsymetricView.cloneView() |
View |
NoopView.cloneView() |
View |
LastPostObserverView.cloneView() |
View |
IntersectDefaultView.cloneView() |
View |
IntersectBatchView.cloneView() |
View |
IntersectAsymetricView.cloneView() |
View[] |
ViewContainer.getViewContained() |
View[] |
UnionView.getViewContained() |
View[] |
UnionAsymetricView.getViewContained() |
View[] |
IntersectDefaultView.getViewContained() |
View[] |
IntersectBatchView.getViewContained() |
View[] |
IntersectAsymetricView.getViewContained() |
View[] |
LastPostObserverView.getViews() |
View |
UnionViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
PriorEventViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
NoopViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
IntersectViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
View |
LastPostObserverView.addView(View view) |
boolean |
UnionViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
PriorEventViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
NoopViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
IntersectViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
LastPostObserverView.removeView(View view) |
static void |
IntersectDefaultView.visitViewContained(ViewDataVisitorContained viewDataVisitor,
ViewFactory viewFactory,
View[] views) |
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 | Class and Description |
---|---|
class |
BaseBivariateStatisticsView
View for computing statistics that require 2 input variable arrays containing X and Y datapoints.
|
class |
CorrelationView
A view that calculates correlation on two fields.
|
class |
RegressionLinestView
A view that calculates regression on two fields.
|
class |
UnivariateStatisticsView
View for computing statistics, which the view exposes via fields representing the sum, count, standard deviation
for sample and for population and variance.
|
class |
WeightedAverageView
View for computing a weighted average.
|
Modifier and Type | Method and Description |
---|---|
View |
WeightedAverageView.cloneView() |
View |
UnivariateStatisticsView.cloneView() |
View |
RegressionLinestView.cloneView() |
View |
CorrelationView.cloneView() |
View |
WeightedAverageViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
UnivariateStatisticsViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
RegressionLinestViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
View |
CorrelationViewFactory.makeView(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
WeightedAverageViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
UnivariateStatisticsViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
RegressionLinestViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
CorrelationViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
GroupByView |
interface |
MergeViewMarker |
Modifier and Type | Class and Description |
---|---|
class |
AddPropertyValueOptionalView
This view simply adds a property to the events posted to it.
|
class |
FirstElementView
View retaining the very first event.
|
class |
FirstUniqueByPropertyView
This view retains the first event for each multi-key of distinct property values.
|
class |
GroupByViewImpl
The group view splits the data in a stream to multiple subviews, based on a key index.
|
class |
GroupByViewReclaimAged |
class |
LastElementView
This view is a very simple view presenting the last event posted by the parent view to any subviews.
|
class |
MergeView
The merge view works together with a group view that splits the data in a stream to multiple subviews, based on
a key index.
|
class |
SizeView
This view is a very simple view presenting the number of elements in a stream or view.
|
class |
UniqueByPropertyView
This view includes only the most recent among events having the same value for the specified field or fields.
|
Modifier and Type | Method and Description |
---|---|
View |
UniqueByPropertyView.cloneView() |
View |
SizeView.cloneView() |
View |
MergeView.cloneView() |
View |
LastElementView.cloneView() |
View |
GroupByViewReclaimAged.cloneView() |
View |
GroupByViewImpl.cloneView() |
View |
FirstUniqueByPropertyView.cloneView() |
View |
FirstElementView.cloneView() |
View |
AddPropertyValueOptionalView.cloneView() |
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) |
Modifier and Type | Method and Description |
---|---|
void |
MergeViewMarker.addParentView(View mergeDataView) |
void |
MergeView.addParentView(View parentView)
Add a parent data merge view.
|
boolean |
UniqueByPropertyViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
SizeViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
MergeViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
LastElementViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
GroupByViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
FirstUniqueByPropertyViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
FirstElementViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
void |
MergeView.removeParentView(View view) |
boolean |
GroupByViewReclaimAged.removeView(View view) |
boolean |
GroupByViewImpl.removeView(View view) |
Modifier and Type | Class and Description |
---|---|
class |
ExpressionBatchView
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
ExpressionViewBase
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
ExpressionWindowView
This view is a moving window extending the into the past until the expression passed to it returns false.
|
class |
ExternallyTimedBatchView
Batch window based on timestamp of arriving events.
|
class |
ExternallyTimedWindowView
View for a moving window extending the specified amount of time into the past, driven entirely by external timing
supplied within long-type timestamp values in a field of the event beans that the view receives.
|
class |
FirstLengthWindowView
A length-first view takes the first N arriving events.
|
class |
FirstTimeView |
class |
KeepAllView
This view is a keep-all data window that simply keeps all events added.
|
class |
LengthBatchView
A data view that aggregates events in a stream and releases them in one batch when a maximum number of events has
been collected.
|
class |
LengthBatchViewRStream
Same as the
LengthBatchView , this view also supports fast-remove from the batch for remove stream events. |
class |
LengthWindowView
This view is a moving window extending the specified number of elements into the past.
|
class |
LengthWindowViewRStream
This view is a moving window extending the specified number of elements into the past,
allowing in addition to remove events efficiently for remove-stream events received by the view.
|
class |
TimeAccumView
A data window view that holds events in a stream and only removes events from a stream (rstream) if
no more events arrive for a given time interval.
|
class |
TimeAccumViewRStream
A data window view that holds events in a stream and only removes events from a stream (rstream) if
no more events arrive for a given time interval, also handling the remove stream
by keeping set-like semantics.
|
class |
TimeBatchView
A data view that aggregates events in a stream and releases them in one batch at every specified time interval.
|
class |
TimeBatchViewRStream
Same as the
TimeBatchView , this view also supports fast-remove from the batch for remove stream events. |
class |
TimeLengthBatchView
A data view that aggregates events in a stream and releases them in one batch if either one of these
conditions is reached, whichever comes first: One, a time interval passes.
|
class |
TimeWindowView
This view is a moving timeWindow extending the specified amount of milliseconds into the past.
|
Modifier and Type | Method and Description |
---|---|
View |
TimeWindowView.cloneView() |
View |
TimeLengthBatchView.cloneView() |
View |
TimeBatchViewRStream.cloneView() |
View |
TimeBatchView.cloneView() |
View |
TimeAccumViewRStream.cloneView() |
View |
TimeAccumView.cloneView() |
View |
LengthWindowViewRStream.cloneView() |
View |
LengthWindowView.cloneView() |
View |
LengthBatchViewRStream.cloneView() |
View |
LengthBatchView.cloneView() |
View |
KeepAllView.cloneView() |
View |
FirstTimeView.cloneView() |
View |
FirstLengthWindowView.cloneView() |
View |
ExternallyTimedWindowView.cloneView() |
View |
ExternallyTimedBatchView.cloneView() |
View |
ExpressionWindowView.cloneView() |
View |
ExpressionBatchView.cloneView() |
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) |
Modifier and Type | Method and Description |
---|---|
boolean |
TimeWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
TimeLengthBatchViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
TimeBatchViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
TimeAccumViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
LengthWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
LengthBatchViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
KeepAllViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
FirstTimeViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
FirstLengthWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
ExternallyTimedWindowViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
ExternallyTimedBatchViewFactory.canReuse(View view,
AgentInstanceContext agentInstanceContext) |
boolean |
ExpressionViewFactoryBase.canReuse(View view,
AgentInstanceContext agentInstanceContext) |