Methods in com.espertech.esper.core.context.activator with parameters of type AgentInstanceContext |
ViewableActivationResult |
ViewableActivatorTable.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivatorSubselectNone.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivatorStreamReuseView.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivatorPattern.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivatorNamedWindow.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivatorFilterProxy.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
ViewableActivationResult |
ViewableActivator.activate(AgentInstanceContext agentInstanceContext,
boolean isSubselect,
boolean isRecoveringResilient)
|
Methods in com.espertech.esper.core.context.factory with parameters of type AgentInstanceContext |
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)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerTable.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSplit.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSetVariable.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerNamedWindow.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks)
|
abstract StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerBase.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks)
|
StatementAgentInstanceFactoryOnTriggerResult |
StatementAgentInstanceFactoryOnTriggerBase.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryCreateTableResult |
StatementAgentInstanceFactoryCreateTable.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryCreateIndexResult |
StatementAgentInstanceFactoryCreateIndex.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryResult |
StatementAgentInstanceFactoryBase.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryResult |
StatementAgentInstanceFactory.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryUpdateResult |
StatementAgentInstanceFactoryUpdate.newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactorySelectResult |
StatementAgentInstanceFactorySelect.newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryCreateWindowResult |
StatementAgentInstanceFactoryCreateWindow.newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryCreateVariableResult |
StatementAgentInstanceFactoryCreateVariable.newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
protected abstract StatementAgentInstanceFactoryResult |
StatementAgentInstanceFactoryBase.newContextInternal(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
Constructors in com.espertech.esper.core.context.factory with parameters of type AgentInstanceContext |
StatementAgentInstanceFactoryCreateIndexResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext)
|
StatementAgentInstanceFactoryCreateTableResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationServiceTable aggregationReportingService)
|
StatementAgentInstanceFactoryCreateVariableResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext)
|
StatementAgentInstanceFactoryCreateWindowResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable eventStreamParentViewable,
StatementAgentInstancePostLoad postLoad,
Viewable topView)
|
StatementAgentInstanceFactoryOnTriggerResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService aggregationService,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies,
EvalRootState optPatternRoot,
java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies)
|
StatementAgentInstanceFactoryResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService optionalAggegationService,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies,
java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies,
java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies,
RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy,
java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies,
java.util.List<StatementAgentInstancePreload> preloadList)
|
StatementAgentInstanceFactorySelectResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService optionalAggegationService,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies,
java.util.Map<ExprPriorNode,ExprPriorEvalStrategy> priorNodeStrategies,
java.util.Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousNodeStrategies,
RegexExprPreviousEvalStrategy regexExprPreviousEvalStrategy,
java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies,
java.util.List<StatementAgentInstancePreload> preloadList,
EvalRootState[] patternRoots,
StatementAgentInstancePostLoad optionalPostLoadJoin,
Viewable[] topViews,
Viewable[] eventStreamViewables)
|
StatementAgentInstanceFactoryUpdateResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies)
|
Constructors in com.espertech.esper.core.context.mgr with parameters of type AgentInstanceContext |
AgentInstance(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView)
|
ContextControllerConditionFilter(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
ContextDetailConditionFilter endpointFilterSpec,
ContextControllerConditionCallback callback,
ContextInternalFilterAddendum filterAddendum)
|
ContextControllerConditionPattern(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
ContextDetailConditionPattern endpointPatternSpec,
ContextControllerConditionCallback callback,
ContextInternalFilterAddendum filterAddendum,
boolean startEndpoint,
ContextStatePathKey contextStatePathKey)
|
ContextControllerConditionTimePeriod(java.lang.String contextName,
AgentInstanceContext agentInstanceContext,
ScheduleSlot scheduleSlot,
ContextDetailConditionTimePeriod spec,
ContextControllerConditionCallback callback,
ContextInternalFilterAddendum filterAddendum)
|
ContextControllerFactoryContext(java.lang.String outermostContextName,
java.lang.String contextName,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContextCreate,
int nestingLevel,
boolean isRecoveringResilient)
|
ContextControllerFactoryServiceContext(java.lang.String contextName,
EPServicesContext servicesContext,
ContextDetail detail,
AgentInstanceContext agentInstanceContextCreate,
boolean isRecoveringResilient)
|
ContextControllerHashedFilterCallback(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContextCreateContext,
ContextDetailHashItem hashItem,
ContextControllerHashedInstanceCallback callback,
ContextInternalFilterAddendum filterAddendum)
|
ContextControllerPartitionedFilterCallback(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContextCreateContext,
ContextDetailPartitionItem partitionItem,
ContextControllerPartitionedInstanceCreateCallback callback,
ContextInternalFilterAddendum filterAddendum)
|
Methods in com.espertech.esper.core.start with parameters of type AgentInstanceContext |
static void |
EPPreparedExecuteTableHelper.assignTableAccessStrategies(EPServicesContext services,
ExprTableAccessNode[] optionalTableNodes,
AgentInstanceContext agentInstanceContext)
|
static java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> |
EPStatementStartMethodHelperTableAccess.attachTableAccess(EPServicesContext services,
AgentInstanceContext agentInstanceContext,
ExprTableAccessNode[] tableNodes)
|
static ResultSetProcessor |
EPStatementStartMethodHelperAssignExpr.getAssignResultSetProcessor(AgentInstanceContext agentInstanceContext,
ResultSetProcessorFactoryDesc resultSetProcessorPrototype)
|
FireAndForgetInstance |
FireAndForgetProcessorTable.getProcessorInstance(AgentInstanceContext agentInstanceContext)
|
FireAndForgetInstance |
FireAndForgetProcessorNamedWindow.getProcessorInstance(AgentInstanceContext agentInstanceContext)
|
abstract FireAndForgetInstance |
FireAndForgetProcessor.getProcessorInstance(AgentInstanceContext agentInstanceContext)
|
static EPStatementStartMethodSelectDesc |
EPStatementStartMethodSelectUtil.prepare(StatementSpecCompiled statementSpec,
EPServicesContext services,
StatementContext statementContext,
boolean recoveringResilient,
AgentInstanceContext defaultAgentInstanceContext,
boolean queryPlanLogging,
ViewableActivatorFactory optionalViewableActivatorFactory,
OutputProcessViewCallback optionalOutputProcessViewCallback,
SelectExprProcessorDeliveryCallback selectExprProcessorDeliveryCallback)
|
static Pair<ResultSetProcessor,AggregationService> |
EPStatementStartMethodHelperUtil.startResultSetAndAggregation(ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
AgentInstanceContext agentInstanceContext)
|
static java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList)
|
Methods in com.espertech.esper.epl.agg.service with parameters of type AgentInstanceContext |
AggSvcGroupByReclaimAgedEvalFunc |
AggSvcGroupByReclaimAgedEvalFuncFactory.make(AgentInstanceContext agentInstanceContext)
|
AggregationServiceMatchRecognize |
AggregationServiceMatchRecognizeFactoryImpl.makeService(AgentInstanceContext agentInstanceContext)
|
AggregationServiceMatchRecognize |
AggregationServiceMatchRecognizeFactory.makeService(AgentInstanceContext agentInstanceContext)
|
AggregationService |
AggSvcGroupByWTableFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByRefcountedWAccessRollupFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByRefcountedWAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByRefcountedNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByReclaimAgedFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupByAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupAllNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupAllMixedAccessWTableFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupAllMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupAllLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggSvcGroupAllAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggregationServiceNullFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
AggregationService |
AggregationServiceFactory.makeService(AgentInstanceContext agentInstanceContext,
MethodResolutionService methodResolutionService)
|
Methods in com.espertech.esper.epl.core with parameters of type AgentInstanceContext |
RowLimitProcessor |
RowLimitProcessorFactory.instantiate(AgentInstanceContext agentInstanceContext)
|
OrderByProcessor |
OrderByProcessorRowLimitOnlyFactory.instantiate(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
OrderByProcessor |
OrderByProcessorOrderedLimitFactory.instantiate(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
OrderByProcessor |
OrderByProcessorFactoryImpl.instantiate(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
OrderByProcessor |
OrderByProcessorFactory.instantiate(AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorSimpleFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorRowPerGroupRollupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorRowPerGroupFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorRowForAllFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorHandThrougFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorAggregateGroupedFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessor |
ResultSetProcessorAggregateAllFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext)
|
void |
ResultSetProcessorSimple.setAgentInstanceContext(AgentInstanceContext context)
|
void |
ResultSetProcessorRowPerGroupRollup.setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
|
void |
ResultSetProcessorRowPerGroup.setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
|
void |
ResultSetProcessorRowForAll.setAgentInstanceContext(AgentInstanceContext context)
|
void |
ResultSetProcessorHandThrough.setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
|
void |
ResultSetProcessorAggregateGrouped.setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
|
void |
ResultSetProcessorAggregateAll.setAgentInstanceContext(AgentInstanceContext context)
|
void |
ResultSetProcessor.setAgentInstanceContext(AgentInstanceContext context)
|
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
java.util.List<GroupByRollupKey> currentGenerators,
boolean newData,
AgentInstanceContext agentInstanceContext,
OrderByElement[][] elementsPerLevel)
|
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
java.util.List<GroupByRollupKey> currentGenerators,
boolean newData,
AgentInstanceContext agentInstanceContext,
OrderByElement[][] elementsPerLevel)
|
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
java.util.List<GroupByRollupKey> currentGenerators,
boolean isNewData,
AgentInstanceContext exprEvaluatorContext,
OrderByElement[][] elementsPerLevel)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
java.util.List<GroupByRollupKey> currentGenerators,
boolean newData,
AgentInstanceContext agentInstanceContext,
OrderByElement[][] elementsPerLevel)
|
Methods in com.espertech.esper.epl.lookup with parameters of type AgentInstanceContext |
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryIndexedUnfiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
java.lang.Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow)
|
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryIndexedFiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
java.lang.Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow)
|
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryAllUnfiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
java.lang.Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow)
|
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactoryAllFiltered.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
java.lang.Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow)
|
SubordWMatchExprLookupStrategy |
SubordWMatchExprLookupStrategyFactory.realize(EventTable[] indexes,
AgentInstanceContext agentInstanceContext,
java.lang.Iterable<EventBean> scanIterable,
VirtualDWView virtualDataWindow)
|
Methods in com.espertech.esper.epl.named with parameters of type AgentInstanceContext |
NamedWindowProcessorInstance |
NamedWindowProcessor.addInstance(AgentInstanceContext agentInstanceContext)
|
NamedWindowProcessorInstance |
NamedWindowProcessor.getProcessorInstance(AgentInstanceContext agentInstanceContext)
|
NamedWindowOnExprBaseView |
NamedWindowOnUpdateViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor)
|
NamedWindowOnExprBaseView |
NamedWindowOnSelectViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor)
|
NamedWindowOnExprBaseView |
NamedWindowOnMergeViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor)
|
NamedWindowOnExprBaseView |
NamedWindowOnExprFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor)
|
NamedWindowOnExprBaseView |
NamedWindowOnDeleteViewFactory.make(SubordWMatchExprLookupStrategy lookupStrategy,
NamedWindowRootViewInstance namedWindowRootViewInstance,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor)
|
Methods in com.espertech.esper.epl.view with parameters of type AgentInstanceContext |
static OutputConditionPolled |
OutputConditionPolledFactory.createCondition(OutputLimitSpec outputLimitSpec,
AgentInstanceContext agentInstanceContext)
Creates an output condition instance. |
OutputStrategyPostProcess |
OutputStrategyPostProcessFactory.make(AgentInstanceContext agentInstanceContext)
|
OutputCondition |
OutputConditionTimeFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionTermFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionNullFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionFirstFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionExpressionFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionCrontabFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputCondition |
OutputConditionCountFactory.make(AgentInstanceContext agentInstanceContext,
OutputCallback outputCallback)
|
OutputProcessViewBase |
OutputProcessViewFactoryCallback.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewBase |
OutputProcessViewFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewBase |
OutputProcessViewDirectFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewBase |
OutputProcessViewDirectDistinctOrAfterFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewBase |
OutputProcessViewConditionFactory.makeView(ResultSetProcessor resultSetProcessor,
AgentInstanceContext agentInstanceContext)
|
Constructors in com.espertech.esper.epl.view with parameters of type AgentInstanceContext |
OutputConditionCrontab(OutputCallback outputCallback,
AgentInstanceContext context,
OutputConditionCrontabFactory factory,
boolean isStartConditionOnCreation)
|
OutputConditionExpression(OutputCallback outputCallback,
AgentInstanceContext agentInstanceContext,
OutputConditionExpressionFactory parent,
boolean isStartConditionOnCreation)
|
OutputConditionFirst(OutputCallback outputCallback,
AgentInstanceContext agentInstanceContext,
OutputConditionFactory innerConditionFactory)
|
OutputConditionPolledCrontab(java.util.List<ExprNode> scheduleSpecExpressionList,
AgentInstanceContext agentInstanceContext)
Constructor. |
OutputConditionPolledExpression(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> assignments,
AgentInstanceContext agentInstanceContext)
Ctor. |
OutputConditionPolledTime(ExprTimePeriod timePeriod,
AgentInstanceContext context)
Constructor. |
OutputConditionTime(OutputCallback outputCallback,
AgentInstanceContext context,
OutputConditionTimeFactory outputConditionTimeFactory,
boolean isStartConditionOnCreation)
|
OutputProcessViewConditionDefault(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionDefaultPostProcess(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputProcessViewConditionFirst(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionFirstPostProcess(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputProcessViewConditionSnapshot(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionSnapshotPostProcess(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputStrategyPostProcess(OutputStrategyPostProcessFactory parent,
AgentInstanceContext agentInstanceContext,
TableStateInstance tableStateInstance)
|
Constructors in com.espertech.esper.rowregex with parameters of type AgentInstanceContext |
EventRowRegexNFAView(EventRowRegexNFAViewFactory factory,
ObjectArrayEventType compositeEventType,
EventType rowEventType,
MatchRecognizeSpec matchRecognizeSpec,
java.util.LinkedHashMap<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
java.util.Map<java.lang.Integer,java.lang.String> streamsVariables,
java.util.Set<java.lang.String> variablesSingle,
AgentInstanceContext agentInstanceContext,
java.util.TreeMap<java.lang.Integer,java.util.List<ExprPreviousMatchRecognizeNode>> callbacksPerIndex,
AggregationServiceMatchRecognize aggregationService,
boolean isDefineAsksMultimatches,
ObjectArrayBackedEventBean defineMultimatchEventBean,
boolean[] isExprRequiresMultimatchState,
boolean isUnbound,
boolean isIterateOnly,
boolean isCollectMultimatches,
RowRegexExprNode expandedPatternNode)
Ctor. |
EventRowRegexNFAViewFactory(ViewFactoryChain viewChain,
MatchRecognizeSpec matchRecognizeSpec,
AgentInstanceContext agentInstanceContext,
boolean isUnbound,
java.lang.annotation.Annotation[] annotations)
Ctor. |