Modifier and Type | Class and Description |
---|---|
class |
ViewableActivatorFilterStopCallback |
Modifier and Type | Method and Description |
---|---|
AgentInstanceStopCallback |
ViewableActivationResult.getStopCallback() |
Constructor and Description |
---|
ViewableActivationResult(Viewable viewable,
AgentInstanceStopCallback stopCallback,
EvalRootMatchRemover optEvalRootMatchRemover,
boolean suppressSameEventMatches,
boolean discardPartialsOnMatch,
EvalRootState optionalPatternRoot,
ViewableActivationResultExtension viewableActivationResultExtension) |
Modifier and Type | Method and Description |
---|---|
AgentInstanceStopCallback |
StatementAgentInstanceFactoryResult.getStopCallback() |
Modifier and Type | Method and Description |
---|---|
void |
StatementAgentInstanceFactoryResult.setStopCallback(AgentInstanceStopCallback stopCallback) |
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) |
Constructor and Description |
---|
StatementAgentInstanceFactoryCreateVariableResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
StatementAgentInstanceFactoryCreateNWResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable eventStreamParentViewable,
Viewable topView,
NamedWindowInstance namedWindowInstance,
ViewableActivationResult viewableActivationResult) |
Modifier and Type | Method and Description |
---|---|
abstract InfraOnExprBaseViewResult |
StatementAgentInstanceFactoryOnTriggerBase.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbacks,
boolean isRecoveringReslient) |
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 | Method and Description |
---|---|
InfraOnExprBaseViewResult |
StatementAgentInstanceFactoryOnTriggerSet.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbacks,
boolean isRecoveringReslient) |
Modifier and Type | Method and Description |
---|---|
InfraOnExprBaseViewResult |
StatementAgentInstanceFactoryOnTriggerSplitStream.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbacks,
boolean isRecoveringReslient) |
Modifier and Type | Method and Description |
---|---|
InfraOnExprBaseViewResult |
StatementAgentInstanceFactoryOnTriggerInfraBase.determineOnExprView(AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbacks,
boolean isRecoveringResilient) |
Constructor and Description |
---|
StatementAgentInstanceFactorySelectResult(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[] patternRoots,
JoinSetComposer joinSetComposer,
Viewable[] topViews,
Viewable[] eventStreamViewables,
ViewableActivationResult[] viewableActivationResults,
ResultSetProcessor resultSetProcessor) |
Constructor and Description |
---|
StatementAgentInstanceFactoryUpdateResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Map<Integer,SubSelectFactoryResult> subselectActivations) |
Modifier and Type | Class and Description |
---|---|
class |
AgentInstanceStopCallbackNoAction |
Modifier and Type | Field and Description |
---|---|
static AgentInstanceStopCallback |
AgentInstanceStopCallback.INSTANCE_NO_ACTION |
Modifier and Type | Method and Description |
---|---|
static AgentInstanceStopCallback |
AgentInstanceUtil.finalizeSafeStopCallbacks(List<AgentInstanceStopCallback> stopCallbacks) |
AgentInstanceStopCallback |
AgentInstance.getStopCallback() |
Modifier and Type | Method and Description |
---|---|
Collection<AgentInstanceStopCallback> |
AgentInstanceContext.getTerminationCallbackRO() |
Modifier and Type | Method and Description |
---|---|
void |
AgentInstanceContext.addTerminationCallback(AgentInstanceStopCallback callback)
Add a stop-callback.
|
void |
AgentInstanceContext.removeTerminationCallback(AgentInstanceStopCallback callback) |
static void |
AgentInstanceUtil.stop(AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
boolean isStatementStop,
boolean leaveLocksAcquired) |
static void |
AgentInstanceUtil.stopSafe(AgentInstanceStopCallback stopMethod,
AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
static AgentInstanceStopCallback |
AgentInstanceUtil.finalizeSafeStopCallbacks(List<AgentInstanceStopCallback> stopCallbacks) |
Constructor and Description |
---|
AgentInstance(AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView) |
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 | 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 |
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 | 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 | Interface and Description |
---|---|
interface |
RowRecogNFAViewService
Service interface for match recognize.
|
Modifier and Type | Class and Description |
---|---|
class |
RowRecogNFAView
View for match recognize support.
|
Modifier and Type | Class and Description |
---|---|
class |
SubqueryIndexStopCallback
Implements a stop callback for use with subqueries to clear their indexes
when a statement is stopped.
|
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) |
static Map<Integer,SubSelectFactoryResult> |
SubSelectHelperStart.startSubselects(Map<Integer,SubSelectFactory> subselects,
AgentInstanceContext agentInstanceContext,
List<AgentInstanceStopCallback> stopCallbacks,
boolean isRecoveringResilient) |
Modifier and Type | Method and Description |
---|---|
AgentInstanceStopCallback |
StatementResourceHolder.getAgentInstanceStopCallback() |
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 |
ViewDataVisitableContainer |
Modifier and Type | Method and Description |
---|---|
static ViewablePair |
ViewFactoryUtil.materialize(ViewFactory[] factories,
Viewable eventStreamParent,
AgentInstanceViewFactoryChainContext viewFactoryChainContext,
List<AgentInstanceStopCallback> stopCallbacks) |
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 |
FirstTimeView |
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 |
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.
|
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.
|
Copyright © 2005–2018. All rights reserved.