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,
boolean isRecoveringReslient)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSplit.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks,
boolean isRecoveringReslient)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerSetVariable.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks,
boolean isRecoveringReslient)
|
StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerNamedWindow.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks,
boolean isRecoveringReslient)
|
abstract StatementAgentInstanceFactoryOnTriggerBase.OnExprViewResult |
StatementAgentInstanceFactoryOnTriggerBase.determineOnExprView(AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbacks,
boolean isRecoveringReslient)
|
StatementAgentInstanceFactoryOnTriggerResult |
StatementAgentInstanceFactoryOnTriggerBase.newContext(AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
StatementAgentInstanceFactoryCreateSchemaResult |
StatementAgentInstanceFactoryNoAgentInstance.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)
|
StatementAgentInstanceFactoryCreateSchemaResult(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,
NamedWindowProcessorInstance processorInstance,
ViewableActivationResult viewableActivationResult)
|
StatementAgentInstanceFactoryOnTriggerResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
AggregationService aggregationService,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies,
EvalRootState optPatternRoot,
java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies,
ViewableActivationResult viewableActivationResult)
|
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,
ViewableActivationResult[] viewableActivationResults)
|
StatementAgentInstanceFactoryUpdateResult(Viewable finalView,
StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies)
|
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,
boolean isSubquery,
java.lang.Integer subqueryNumber,
boolean isFireAndForget)
|
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,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
static java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList,
boolean isRecoveringResilient)
|
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,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByRefcountedWAccessRollupFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByRefcountedWAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByRefcountedNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByReclaimAgedFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupByAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupAllNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupAllMixedAccessWTableFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupAllMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupAllLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggSvcGroupAllAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggregationServiceNullFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
AggregationService |
AggregationServiceFactory.makeService(AgentInstanceContext agentInstanceContext,
EngineImportService engineImportService,
boolean isSubquery,
java.lang.Integer subqueryNumber)
|
Methods in com.espertech.esper.epl.core with parameters of type AgentInstanceContext |
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelperImpl.getOrAllocate(java.lang.Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory factory)
|
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelper.getOrAllocate(java.lang.Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory optionalOutputFirstConditionFactory)
|
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 |
ResultSetProcessorHandThroughFactory.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)
|
OutputProcessViewAfterState |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionAfter(java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewAfterState |
ResultSetProcessorHelperFactory.makeOutputConditionAfter(java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionDeltaSet |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionChangeSet(boolean isJoin,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionDeltaSet |
ResultSetProcessorHelperFactory.makeOutputConditionChangeSet(boolean isJoin,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorAggregateAllOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorAggregateAllOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSAggregateAllOutputAll(ResultSetProcessorAggregateAll processor,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorAggregateAllOutputLastHelperImpl |
ResultSetProcessorHelperFactoryImpl.makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorAggregateAllOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSAggregateAllOutputLast(ResultSetProcessorAggregateAll processor,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorAggregateGroupedOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext,
ResultSetProcessorAggregateGrouped processor,
ResultSetProcessorAggregateGroupedFactory prototype)
|
ResultSetProcessorAggregateGroupedOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSAggregateGroupedOutputAll(AgentInstanceContext agentInstanceContext,
ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped,
ResultSetProcessorAggregateGroupedFactory prototype)
|
ResultSetProcessorAggregateGroupedOutputLastHelper |
ResultSetProcessorHelperFactoryImpl.makeRSAggregateGroupedOutputLastOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped,
ResultSetProcessorAggregateGroupedFactory prototype)
|
ResultSetProcessorAggregateGroupedOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSAggregateGroupedOutputLastOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorAggregateGrouped resultSetProcessorAggregateGrouped,
ResultSetProcessorAggregateGroupedFactory prototype)
|
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyExpressions,
int numStreams)
|
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactory.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyExpressions,
int numStreams)
|
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel)
|
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel)
|
ResultSetProcessorRowForAllOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowForAllOutputAll(ResultSetProcessorRowForAll processor,
ResultSetProcessorRowForAllFactory prototype,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorRowForAllOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSRowForAllOutputAll(ResultSetProcessorRowForAll processor,
ResultSetProcessorRowForAllFactory prototype,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorRowForAllOutputLastHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowForAllOutputLast(ResultSetProcessorRowForAll processor,
ResultSetProcessorRowForAllFactory prototype,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorRowForAllOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSRowForAllOutputLast(ResultSetProcessorRowForAll processor,
ResultSetProcessorRowForAllFactory prototype,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorRowPerGroupOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupOutputAllOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorRowPerGroupOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSRowPerGroupOutputAllOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorRowPerGroupOutputLastHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupOutputLastOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorRowPerGroupOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSRowPerGroupOutputLastOpt(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroup resultSetProcessorRowPerGroup,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupRollupAll(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSRowPerGroupRollupAll(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupOutputLastHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupRollupLast(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSRowPerGroupRollupLast(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollup resultSetProcessorRowPerGroupRollup,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupUnboundHelper |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupRollupSnapshotUnbound(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupRollupUnboundHelper |
ResultSetProcessorHelperFactory.makeRSRowPerGroupRollupSnapshotUnbound(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupRollupFactory prototype)
|
ResultSetProcessorRowPerGroupUnboundGroupRep |
ResultSetProcessorHelperFactoryImpl.makeRSRowPerGroupUnboundGroupRep(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorRowPerGroupUnboundGroupRep |
ResultSetProcessorHelperFactory.makeRSRowPerGroupUnboundGroupRep(AgentInstanceContext agentInstanceContext,
ResultSetProcessorRowPerGroupFactory prototype)
|
ResultSetProcessorSimpleOutputAllHelper |
ResultSetProcessorHelperFactoryImpl.makeRSSimpleOutputAll(ResultSetProcessorSimpleFactory prototype,
ResultSetProcessorSimple resultSetProcessorSimple,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorSimpleOutputAllHelper |
ResultSetProcessorHelperFactory.makeRSSimpleOutputAll(ResultSetProcessorSimpleFactory prototype,
ResultSetProcessorSimple resultSetProcessorSimple,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorSimpleOutputLastHelper |
ResultSetProcessorHelperFactoryImpl.makeRSSimpleOutputLast(ResultSetProcessorSimpleFactory prototype,
ResultSetProcessorSimple simple,
AgentInstanceContext agentInstanceContext)
|
ResultSetProcessorSimpleOutputLastHelper |
ResultSetProcessorHelperFactory.makeRSSimpleOutputLast(ResultSetProcessorSimpleFactory prototype,
ResultSetProcessorSimple simple,
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 |
void |
EventTableIndexRepository.addExplicitIndex(java.lang.String indexName,
EventTableCreateIndexDesc desc,
EventType eventType,
java.lang.Iterable<EventBean> dataWindowContents,
AgentInstanceContext agentInstanceContext,
java.lang.Object optionalSerde)
|
Pair<IndexMultiKey,EventTableAndNamePair> |
EventTableIndexRepository.addExplicitIndexOrReuse(boolean unique,
java.util.List<IndexedPropDesc> hashProps,
java.util.List<IndexedPropDesc> btreeProps,
java.lang.Iterable<EventBean> prefilledEvents,
EventType indexedType,
java.lang.String indexName,
AgentInstanceContext agentInstanceContext,
java.lang.Object optionalSerde)
|
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)
|
static EventTable[] |
SubordinateQueryPlannerUtil.realizeTables(SubordinateQueryIndexDesc[] indexDescriptors,
EventType eventType,
EventTableIndexRepository indexRepository,
java.lang.Iterable<EventBean> contents,
AgentInstanceContext agentInstanceContext,
boolean isRecoveringResilient)
|
void |
EventTableIndexRepository.validateAddExplicitIndex(boolean unique,
java.lang.String indexName,
java.util.List<CreateIndexItem> columns,
EventType eventType,
java.lang.Iterable<EventBean> dataWindowContents,
AgentInstanceContext agentInstanceContext,
boolean allowIndexExists,
java.lang.Object optionalSerde)
|
Methods in com.espertech.esper.epl.view with parameters of type AgentInstanceContext |
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)
|
OutputConditionPolled |
OutputConditionPolledTimeFactory.makeFromState(AgentInstanceContext agentInstanceContext,
OutputConditionPolledState state)
|
OutputConditionPolled |
OutputConditionPolledFactory.makeFromState(AgentInstanceContext agentInstanceContext,
OutputConditionPolledState state)
|
OutputConditionPolled |
OutputConditionPolledExpressionFactory.makeFromState(AgentInstanceContext agentInstanceContext,
OutputConditionPolledState state)
|
OutputConditionPolled |
OutputConditionPolledCrontabFactory.makeFromState(AgentInstanceContext agentInstanceContext,
OutputConditionPolledState state)
|
OutputConditionPolled |
OutputConditionPolledCountFactory.makeFromState(AgentInstanceContext agentInstanceContext,
OutputConditionPolledState state)
|
OutputConditionPolled |
OutputConditionPolledTimeFactory.makeNew(AgentInstanceContext agentInstanceContext)
|
OutputConditionPolled |
OutputConditionPolledFactory.makeNew(AgentInstanceContext agentInstanceContext)
|
OutputConditionPolled |
OutputConditionPolledExpressionFactory.makeNew(AgentInstanceContext agentInstanceContext)
|
OutputConditionPolled |
OutputConditionPolledCrontabFactory.makeNew(AgentInstanceContext agentInstanceContext)
|
OutputConditionPolled |
OutputConditionPolledCountFactory.makeNew(AgentInstanceContext agentInstanceContext)
|
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(AgentInstanceContext agentInstanceContext,
OutputConditionPolledCrontabState state)
|
OutputConditionPolledExpression(OutputConditionPolledExpressionFactory factory,
OutputConditionPolledExpressionState state,
AgentInstanceContext agentInstanceContext,
ObjectArrayEventBean builtinProperties)
|
OutputConditionPolledTime(OutputConditionPolledTimeFactory factory,
AgentInstanceContext context,
OutputConditionPolledTimeState state)
|
OutputConditionTime(OutputCallback outputCallback,
AgentInstanceContext context,
OutputConditionTimeFactory outputConditionTimeFactory,
boolean isStartConditionOnCreation)
|
OutputProcessViewBaseWAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied)
|
OutputProcessViewConditionDefault(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
boolean isJoin)
|
OutputProcessViewConditionDefaultPostProcess(ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor,
boolean isJoin,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory)
|
OutputProcessViewConditionFirst(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionFirstPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputProcessViewConditionLastAllUnord(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionLastAllUnordPostProcessAll(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputProcessViewConditionSnapshot(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext)
|
OutputProcessViewConditionSnapshotPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewConditionFactory parent,
AgentInstanceContext agentInstanceContext,
OutputStrategyPostProcess postProcessor)
|
OutputProcessViewDirectDistinctOrAfter(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewDirectDistinctOrAfterFactory parent)
|
OutputProcessViewDirectDistinctOrAfterPostProcess(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
ResultSetProcessor resultSetProcessor,
java.lang.Long afterConditionTime,
java.lang.Integer afterConditionNumberOfEvents,
boolean afterConditionSatisfied,
OutputProcessViewDirectDistinctOrAfterFactory parent,
OutputStrategyPostProcess postProcessor)
|
OutputStrategyPostProcess(OutputStrategyPostProcessFactory parent,
AgentInstanceContext agentInstanceContext,
TableStateInstance tableStateInstance)
|
Methods in com.espertech.esper.rowregex with parameters of type AgentInstanceContext |
void |
MatchRecognizeStatePoolEngineSvc.decreaseCount(AgentInstanceContext agentInstanceContext)
|
void |
MatchRecognizeStatePoolEngineSvc.decreaseCount(AgentInstanceContext agentInstanceContext,
int numRemoved)
|
RegexPartitionStateRepo |
RegexHandlerFactoryDefault.makePartitioned(RegexPartitionStateRandomAccessGetter prevGetter,
RegexPartitionStateRepoGroupMeta stateRepoGroupMeta,
AgentInstanceContext agentInstanceContext,
EventRowRegexNFAView view,
boolean keepScheduleState,
RegexPartitionTerminationStateComparator terminationStateCompare)
|
RegexPartitionStateRepo |
RegexHandlerFactory.makePartitioned(RegexPartitionStateRandomAccessGetter prevGetter,
RegexPartitionStateRepoGroupMeta stateRepoGroupMeta,
AgentInstanceContext agentInstanceContext,
EventRowRegexNFAView view,
boolean keepScheduleState,
RegexPartitionTerminationStateComparator terminationStateCompare)
|
RegexPartitionStateRepo |
RegexHandlerFactoryDefault.makeSingle(RegexPartitionStateRandomAccessGetter prevGetter,
AgentInstanceContext agentInstanceContext,
EventRowRegexNFAView view,
boolean keepScheduleState,
RegexPartitionTerminationStateComparator terminationStateCompare)
|
RegexPartitionStateRepo |
RegexHandlerFactory.makeSingle(RegexPartitionStateRandomAccessGetter prevGetter,
AgentInstanceContext agentInstanceContext,
EventRowRegexNFAView view,
boolean keepScheduleState,
RegexPartitionTerminationStateComparator terminationStateCompare)
|
EventRowRegexNFAViewFactory |
RegexHandlerFactoryDefault.makeViewFactory(ViewFactoryChain viewFactoryChain,
MatchRecognizeSpec matchRecognizeSpec,
AgentInstanceContext agentInstanceContext,
boolean isUnbound,
java.lang.annotation.Annotation[] annotations,
ConfigurationEngineDefaults.MatchRecognize matchRecognizeConfigs)
|
EventRowRegexNFAViewFactory |
RegexHandlerFactory.makeViewFactory(ViewFactoryChain viewFactoryChain,
MatchRecognizeSpec matchRecognizeSpec,
AgentInstanceContext agentInstanceContext,
boolean isUnbound,
java.lang.annotation.Annotation[] annotations,
ConfigurationEngineDefaults.MatchRecognize matchRecognizeConfigs)
|
void |
EventRowRegexNFAViewSchedulerImpl.setScheduleCallback(AgentInstanceContext agentInstanceContext,
EventRowRegexNFAViewScheduleCallback scheduleCallback)
|
void |
EventRowRegexNFAViewScheduler.setScheduleCallback(AgentInstanceContext agentInstanceContext,
EventRowRegexNFAViewScheduleCallback scheduleCallback)
|
boolean |
MatchRecognizeStatePoolEngineSvc.tryIncreaseCount(AgentInstanceContext agentInstanceContext)
|