| Modifier and Type | Method and Description |
|---|---|
Viewable |
ViewableActivationResult.getViewable() |
| Constructor and Description |
|---|
ViewableActivationResult(Viewable viewable,
AgentInstanceStopCallback stopCallback,
EvalRootMatchRemover optEvalRootMatchRemover,
boolean suppressSameEventMatches,
boolean discardPartialsOnMatch,
EvalRootState optionalPatternRoot,
ViewableActivationResultExtension viewableActivationResultExtension) |
| Modifier and Type | Method and Description |
|---|---|
Viewable |
StatementAgentInstanceFactoryResult.getFinalView() |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService optionalAggegationService,
Map<Integer,SubSelectFactoryResult> subselectStrategies,
PriorEvalStrategy[] priorStrategies,
PreviousGetterStrategy[] previousGetterStrategies,
RowRecogPreviousStrategy rowRecogPreviousStrategy,
Map<Integer,ExprTableEvalStrategy> tableAccessStrategies,
List<StatementAgentInstancePreload> preloadList) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateContextResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService optionalAggegationService,
Map<Integer,SubSelectFactoryResult> subselectStrategies,
PriorEvalStrategy[] priorStrategies,
PreviousGetterStrategy[] previousGetterStrategies,
RowRecogPreviousStrategy regexExprPreviousEvalStrategy,
Map<Integer,ExprTableEvalStrategy> tableAccessStrategies,
List<StatementAgentInstancePreload> preloadList,
ContextManagerRealization contextManagerRealization) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateDataflowResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
DataflowDesc dataflow) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateExpressionResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateIndexResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateSchemaResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateTableResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
TableInstance tableInstance) |
| Modifier and Type | Class and Description |
|---|---|
class |
CreateVariableView |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateVariableResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext) |
| Modifier and Type | Method and Description |
|---|---|
Viewable |
StatementAgentInstanceFactoryCreateNWResult.getEventStreamParentViewable() |
Viewable |
StatementAgentInstanceFactoryCreateNWResult.getTopView() |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateNWResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable eventStreamParentViewable,
Viewable topView,
NamedWindowInstance namedWindowInstance,
ViewableActivationResult viewableActivationResult) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryOnTriggerResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService optionalAggegationService,
Map<Integer,SubSelectFactoryResult> subselectStrategies,
PriorEvalStrategy[] priorStrategies,
PreviousGetterStrategy[] previousGetterStrategies,
RowRecogPreviousStrategy regexExprPreviousEvalStrategy,
Map<Integer,ExprTableEvalStrategy> tableAccessStrategies,
List<StatementAgentInstancePreload> preloadList,
EvalRootState optPatternRoot,
ViewableActivationResult viewableActivationResult) |
| Modifier and Type | Class and Description |
|---|---|
class |
OnSetVariableView
A view that handles the setting of variables upon receipt of a triggering event.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RouteResultView
View for processing split-stream syntax.
|
| Modifier and Type | Method and Description |
|---|---|
Viewable[] |
StatementAgentInstanceFactorySelectResult.getEventStreamViewables() |
Viewable[] |
StatementAgentInstanceFactorySelectResult.getTopViews() |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryUpdateResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Map<Integer,SubSelectFactoryResult> subselectActivations) |
| Modifier and Type | Class and Description |
|---|---|
class |
ContextMergeView |
class |
ContextMergeViewForwarding |
class |
InternalRoutePreprocessView
View for use with pre-processing statement such as "update istream" for indicating previous and current event.
|
| Modifier and Type | Method and Description |
|---|---|
Viewable |
AgentInstance.getFinalView() |
| Modifier and Type | Method and Description |
|---|---|
static void |
AgentInstanceUtil.stop(AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
boolean isStatementStop,
boolean leaveLocksAcquired) |
| Constructor and Description |
|---|
AgentInstance(AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView) |
| Modifier and Type | Method and Description |
|---|---|
Viewable |
FireAndForgetInstanceTable.getTailViewInstance() |
Viewable |
FireAndForgetInstanceNamedWindow.getTailViewInstance() |
abstract Viewable |
FireAndForgetInstance.getTailViewInstance() |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HistoricalEventViewable
Interface for views that poll data based on information from other streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HistoricalEventViewableBase
Implements a poller viewable that uses a polling strategy, a cache and
some input parameters extracted from event streams to perform the polling.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HistoricalEventViewableDatabase |
| Modifier and Type | Class and Description |
|---|---|
class |
HistoricalEventViewableMethod |
| Modifier and Type | Method and Description |
|---|---|
JoinSetComposerDesc |
JoinSetComposerPrototypeHistorical2Stream.create(Viewable[] streamViews,
boolean isFireAndForget,
AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient) |
JoinSetComposerDesc |
JoinSetComposerPrototypeGeneral.create(Viewable[] streamViews,
boolean isFireAndForget,
AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient) |
JoinSetComposerDesc |
JoinSetComposerPrototype.create(Viewable[] streamViews,
boolean isFireAndForget,
AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient) |
| Constructor and Description |
|---|
JoinSetComposerHistoricalImpl(boolean allowInitIndex,
Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
Viewable[] streamViews,
ExprEvaluatorContext staticEvalExprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
ExecNode |
TableOuterLookupNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
TableLookupNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeNoOp.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
QueryPlanNodeAllUnidirectionalOuter.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
abstract ExecNode |
QueryPlanNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
NestedIterationNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
LookupInstructionQueryPlanNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
ExecNode |
HistoricalDataPlanNode.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal,
Lock[] tableSecondaryIndexLocks) |
HistoricalTableLookupStrategy |
HistoricalDataPlanNode.makeOuterJoinStategy(Viewable[] streamViews)
Returns the table lookup strategy for use in outer joins.
|
| Modifier and Type | Method and Description |
|---|---|
LookupInstructionExec |
LookupInstructionPlan.makeExec(AgentInstanceContext agentInstanceContext,
Map<TableLookupIndexReqKey,EventTable>[] indexesPerStream,
EventType[] streamTypes,
Viewable[] streamViews,
VirtualDWView[] viewExternal) |
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NamedWindowOutputProcessView |
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
NamedWindowManagementService to consuming statements. |
| Modifier and Type | Method and Description |
|---|---|
void |
NamedWindowRootViewInstance.setParent(Viewable parent) |
| Modifier and Type | Class and Description |
|---|---|
class |
OnExprViewNamedWindowDelete
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewNamedWindowMerge
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewNamedWindowMergeInsertUnmatched
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewNamedWindowSelect
View for the on-select statement that handles selecting events from a named window.
|
class |
OnExprViewNamedWindowUpdate
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewNameWindowBase
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewTableBase |
class |
OnExprViewTableDelete
View for the on-delete statement that handles removing events from a named window.
|
class |
OnExprViewTableMerge |
class |
OnExprViewTableMergeInsertUnmatched |
class |
OnExprViewTableSelect |
class |
OnExprViewTableUpdate |
| Modifier and Type | Class and Description |
|---|---|
class |
OutputProcessViewConditionDefaultPostProcess
A view that prepares output events, batching incoming
events and invoking the result set processor as necessary.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OutputProcessView |
class |
OutputProcessViewConditionLastAllUnordPostProcessAll |
class |
OutputProcessViewConditionSnapshot
A view that handles the "output snapshot" keyword in output rate stabilizing.
|
class |
OutputProcessViewSimple |
class |
OutputProcessViewSimpleWProcessor |
| Modifier and Type | Field and Description |
|---|---|
protected Viewable |
OutputProcessView.parentView |
| Modifier and Type | Method and Description |
|---|---|
Viewable |
OutputProcessView.getParent() |
| Modifier and Type | Method and Description |
|---|---|
static Iterator<EventBean> |
OutputStrategyUtil.getIterator(JoinExecutionStrategy joinExecutionStrategy,
ResultSetProcessor resultSetProcessor,
Viewable parentView,
boolean distinct)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
void |
OutputProcessView.setParent(Viewable parent) |
| Modifier and Type | Class and Description |
|---|---|
class |
OutputProcessViewBaseWAfter |
class |
OutputProcessViewConditionDefault
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 |
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 |
|---|---|
static void |
ResultSetProcessorUtil.clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService,
Viewable parent) |
Iterator<EventBean> |
ResultSetProcessor.getIterator(Viewable parent)
Returns the iterator implementing the group-by and aggregation and order-by logic
specific to each case of use of these construct.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RowRecogNFAView
View for match recognize support.
|
| Modifier and Type | Method and Description |
|---|---|
static RowRecogNFAViewService |
RowRecogHelper.recursiveFindRegexService(Viewable top) |
| 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 | Method and Description |
|---|---|
Viewable |
SubSelectStrategyRealization.getSubselectView() |
Viewable |
SubSelectFactoryResult.getSubselectView() |
| Modifier and Type | Method and Description |
|---|---|
SubSelectStrategyRealization |
SubSelectStrategyFactoryLocalViewPreloaded.instantiate(Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactoryIndexShare.instantiate(Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactory.instantiate(Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
| Constructor and Description |
|---|
SubSelectStrategyRealization(SubordTableLookupStrategy lookupStrategy,
SubselectAggregationPreprocessorBase subselectAggregationPreprocessor,
AggregationService aggregationService,
PriorEvalStrategy priorStrategy,
PreviousGetterStrategy previousStrategy,
Viewable subselectView,
EventTable[] indexes) |
| Modifier and Type | Class and Description |
|---|---|
class |
TableInstanceViewable |
class |
TableStateViewableInternal |
| Modifier and Type | Class and Description |
|---|---|
class |
VirtualDWViewImpl |
| Modifier and Type | Interface and Description |
|---|---|
interface |
UpdateDispatchView
Update dispatch view to indicate statement results to listeners.
|
| Modifier and Type | Method and Description |
|---|---|
Viewable[] |
StatementResourceHolder.getEventStreamViewables() |
Viewable |
StatementResourceHolder.getFinalView() |
Viewable[] |
StatementResourceHolder.getTopViewables() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
StatementResourceHolder.setEventStreamViewables(Viewable[] eventStreamViewables) |
protected void |
StatementResourceHolder.setTopViewables(Viewable[] topViewables) |
| Constructor and Description |
|---|
StatementResourceHolder(AgentInstanceContext agentInstanceContext,
AgentInstanceStopCallback agentInstanceStopCallback,
Viewable finalView,
AggregationService aggregationService,
PriorEvalStrategy[] priorEvalStrategies,
PreviousGetterStrategy[] previousGetterStrategies,
RowRecogPreviousStrategy rowRecogPreviousStrategy) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DataWindowView
Tag interface for data window views.
|
interface |
DerivedValueView
Tag interface for derived-value views.
|
interface |
EventStream
A streams is a conduct for incoming events.
|
interface |
View
The View interface provides a way for a stream, data provider, or another view,
to notify an object of additions and deletions to its data set.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PatternRemoveDispatchView
View to handle pattern discarding for a single stream (no join).
|
class |
SingleStreamDispatchView
View to dispatch for a single stream (no join).
|
class |
ViewableDefaultImpl |
class |
ViewNoop |
class |
ViewSupport |
class |
ZeroDepthStreamIterable
Event stream implementation that does not keep any window by itself of the events coming into the stream,
however is itself iterable and keeps the last event.
|
class |
ZeroDepthStreamIterableWAudit
Event stream implementation that does not keep any window by itself of the events coming into the stream,
however is itself iterable and keeps the last event.
|
class |
ZeroDepthStreamNoIterate
Event stream implementation that does not keep any window by itself of the events coming into the stream,
without the possibility to iterate the last event.
|
class |
ZeroDepthStreamNoIterateWAudit |
| Modifier and Type | Field and Description |
|---|---|
protected Viewable |
ViewSupport.parent |
| Modifier and Type | Method and Description |
|---|---|
Viewable |
ViewablePair.getLast() |
Viewable |
ViewSupport.getParent() |
Viewable |
ViewNoop.getParent() |
Viewable |
View.getParent()
Returns the View's parent Viewable.
|
Viewable |
ViewablePair.getTop() |
| Modifier and Type | Method and Description |
|---|---|
static ViewablePair |
ViewFactoryUtil.materialize(ViewFactory[] factories,
Viewable eventStreamParent,
AgentInstanceViewFactoryChainContext viewFactoryChainContext,
List<AgentInstanceStopCallback> stopCallbacks) |
void |
ViewSupport.setParent(Viewable parent) |
void |
ViewNoop.setParent(Viewable parent) |
void |
View.setParent(Viewable parent)
Called when the View is added to a Viewable object.
|
| Constructor and Description |
|---|
ViewablePair(Viewable top,
Viewable last) |
| 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 |
SizeView
This view is a very simple view presenting the number of elements in a stream or view.
|
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 | 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExternallyTimedBatchView
Batch window based on timestamp of arriving events.
|
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FilterExprView
Simple filter view filtering events using a filter expression tree.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FirstEventView
View retaining the very first event.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FirstLengthWindowView
A length-first view takes the first N arriving events.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FirstTimeView |
| Modifier and Type | Class and Description |
|---|---|
class |
FirstUniqueByPropertyView
This view retains the first event for each multi-key of distinct property values.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
GroupByView |
| Modifier and Type | Class and Description |
|---|---|
class |
AddPropertyValueOptionalView
This view simply adds a property to the events posted to it.
|
class |
GroupByViewImpl
The group view splits the data in a stream to multiple subviews, based on a key index.
|
class |
GroupByViewReclaimAged |
class |
MergeView |
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Method and Description |
|---|---|
Viewable |
LastPostObserverView.getParent() |
| Modifier and Type | Method and Description |
|---|---|
void |
LastPostObserverView.setParent(Viewable parent) |
| Modifier and Type | Class and Description |
|---|---|
class |
KeepAllView
This view is a keep-all data window that simply keeps all events added.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LastEventView
This view is a very simple view presenting the last event posted by the parent view to any subviews.
|
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
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. |
| Modifier and Type | Class and Description |
|---|---|
class |
PriorEventView
View that provides access to prior events posted by the parent view for use by 'prior' expression nodes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PriorEventView.setParent(Viewable parent) |
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
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. |
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
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 | Class and Description |
|---|---|
class |
TimeWindowView
This view is a moving timeWindow extending the specified amount of milliseconds into the past.
|
| Modifier and Type | Class and Description |
|---|---|
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 | Class and Description |
|---|---|
class |
UniqueByPropertyView
This view includes only the most recent among events having the same value for the specified field or fields.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BufferView
A view that acts as an adapter between views and update listeners.
|
Copyright © 2005–2018. All rights reserved.