Uses of Interface
com.espertech.esper.epl.core.EngineImportService

Packages that use EngineImportService

Package	Description
com.espertech.esper.codegen.compile	Code-Generation Compiler
com.espertech.esper.core.context.activator	Activation of streams for statement start.
com.espertech.esper.core.context.mgr	Context management.
com.espertech.esper.core.context.subselect	Subselect implementation.
com.espertech.esper.core.deploy	Module and deployment utility and parser.
com.espertech.esper.core.service	Implementation of client package interfaces, glue code
com.espertech.esper.dataflow.core	Data flow core classes.
com.espertech.esper.epl.agg.factory	Aggregator factories
com.espertech.esper.epl.agg.service	Aggregation services.
com.espertech.esper.epl.agg.util	Aggregation utility classes centered around local group-by parameters.
com.espertech.esper.epl.annotation	Classes for EPL annotation processing.
com.espertech.esper.epl.core	Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.
com.espertech.esper.epl.core.eval	Select expression evaluators.
com.espertech.esper.epl.db	Database SQL polling views and caches
com.espertech.esper.epl.enummethod.dot	Enumeration method utility classes and input data sources.
com.espertech.esper.epl.enummethod.eval	Enumeration method implementations.
com.espertech.esper.epl.expression.accessagg	Access-aggregation expressions.
com.espertech.esper.epl.expression.core	Core expression classes.
com.espertech.esper.epl.expression.dot	Chained expression functionality.
com.espertech.esper.epl.expression.subquery	Subselect expressions.
com.espertech.esper.epl.join.base	Join process interfaces and glue code
com.espertech.esper.epl.join.plan	Inner join and outer join query planning
com.espertech.esper.epl.join.util	Join-related utilities
com.espertech.esper.epl.lookup	Subquery execution strategies and lookup indexes
com.espertech.esper.epl.named	Named window classes are in this package
com.espertech.esper.epl.parse	Parsers and AST tree walkers and helper classes transforming AST into business objects
com.espertech.esper.epl.property	Classes for handling events-within-events.
com.espertech.esper.epl.script.mvel	MVEL script expression evaluation.
com.espertech.esper.epl.spec	Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.
com.espertech.esper.epl.table.merge	Table on-merge handlers.
com.espertech.esper.epl.table.mgmt	Table-related services and metadata.
com.espertech.esper.epl.variable	Variable service and variable collections
com.espertech.esper.event	This package defines the internal event APIs.
com.espertech.esper.event.avro	Avro event type core interfaces.
com.espertech.esper.event.bean	JavaBean and legacy Java underlying event classes are here.
com.espertech.esper.event.xml	XML event wrappers
com.espertech.esper.filter	Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
com.espertech.esper.pattern	Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active pattern instance
com.espertech.esper.util	Utility classes that center around Java type handling, printing, reflection, debugging
com.espertech.esper.view	View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
com.espertech.esper.view.stat	Views computing statistical values.

Uses of EngineImportService in com.espertech.esper.codegen.compile

Methods in com.espertech.esper.codegen.compile with parameters of type EngineImportService

Modifier and Type	Method and Description
static <T> T	CodegenClassGenerator.compile(CodegenClass clazz, EngineImportService engineImportService, Class<T> interfaceClass, Supplier<String> debugInformation)
static ExprEvaluator	CodegenExprEvaluator.compile(String engineURI, EngineImportService engineImportService, CodegenExpression expression, CodegenContext codegenContext, Class returnType, Supplier<String> debugInformationProvider)
static EventPropertyGetterIndexed	CodegenEventPropertyGetter.compile(String engineURI, EngineImportService engineImportService, EventPropertyGetterIndexedSPI getterSPI, Supplier<String> debugInfoSupplier, boolean includeCodeComments)
static EventPropertyGetterMapped	CodegenEventPropertyGetter.compile(String engineURI, EngineImportService engineImportService, EventPropertyGetterMappedSPI getterSPI, Supplier<String> debugInfoSupplier, boolean includeCodeComments)
static EventPropertyGetter	CodegenEventPropertyGetter.compile(String engineURI, EngineImportService engineImportService, EventPropertyGetterSPI getterSPI, Supplier<String> debugInfoSupplier, boolean includeCodeComments)

Uses of EngineImportService in com.espertech.esper.core.context.activator

Constructors in com.espertech.esper.core.context.activator with parameters of type EngineImportService

Constructor and Description
ViewableActivatorNamedWindow(NamedWindowProcessor processor, List<ExprNode> filterExpressions, PropertyEvaluator optPropertyEvaluator, EngineImportService engineImportService, String statementName)

Uses of EngineImportService in com.espertech.esper.core.context.mgr

Constructors in com.espertech.esper.core.context.mgr with parameters of type EngineImportService

Constructor and Description
ContextControllerHashedGetterCRC32Serialized(String statementName, List<ExprNode> nodes, int granularity, EngineImportService engineImportService)
ContextControllerHashedGetterHashMultiple(List<ExprNode> nodes, int granularity, EngineImportService engineImportService, String statementName)
ContextControllerHashedGetterSingleRow(String statementName, String functionName, Pair<Class,EngineImportSingleRowDesc> func, List<ExprNode> parameters, int granularity, EngineImportService engineImportService, EventType eventType, EventAdapterService eventAdapterService, int statementId, TableService tableService, String engineURI)

Uses of EngineImportService in com.espertech.esper.core.context.subselect

Constructors in com.espertech.esper.core.context.subselect with parameters of type EngineImportService

Constructor and Description

SubSelectStrategyFactoryIndexShare(String statementName, int statementId, int subqueryNum, EventType[] outerEventTypesSelect, NamedWindowProcessor optionalNamedWindowProcessor, TableMetadata optionalTableMetadata, boolean fullTableScan, IndexHint optionalIndexHint, SubordPropPlan joinedPropPlan, ExprEvaluator filterExprEval, AggregationServiceFactoryDesc aggregationServiceFactory, ExprEvaluator[] groupByKeys, TableService tableService, Annotation[] annotations, StatementStopService statementStopService, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.core.deploy

Methods in com.espertech.esper.core.deploy with parameters of type EngineImportService

Modifier and Type	Method and Description
static Module	EPLModuleUtil.readResource(String resource, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.core.service

Methods in com.espertech.esper.core.service that return EngineImportService

Modifier and Type	Method and Description
EngineImportService	StatementContextEngineServices.getEngineImportService()
EngineImportService	StatementContext.getEngineImportService()
EngineImportService	EPServicesContext.getEngineImportService() Returns the import and class name resolution service.
EngineImportService	EPServiceProviderSPI.getEngineImportService() Returns engine imports.
EngineImportService	EPServiceProviderImpl.getEngineImportService()
protected static EngineImportService	EPServicesContextFactoryDefault.makeEngineImportService(ConfigurationInformation configSnapshot, AggregationFactoryFactory aggregationFactoryFactory, String engineURI) Constructs the auto import service.

Methods in com.espertech.esper.core.service with parameters of type EngineImportService

Modifier and Type	Method and Description
static StatementSpecRaw	EPAdministratorHelper.compileEPL(String eplStatement, String eplStatementForErrorMsg, boolean addPleaseCheck, String statementName, SelectClauseStreamSelectorEnum defaultStreamSelector, EngineImportService engineImportService, VariableService variableService, SchedulingService schedulingService, String engineURI, ConfigurationInformation configSnapshot, PatternNodeFactory patternNodeFactory, ContextManagementService contextManagementService, ExprDeclaredService exprDeclaredService, TableService tableService)
static ResultDeliveryStrategy	ResultDeliveryStrategyFactory.create(EPStatement statement, Object subscriber, String methodName, Class[] selectClauseTypes, String[] selectClauseColumns, String engineURI, EngineImportService engineImportService) Creates a strategy implementation that indicates to subscribers the statement results based on the select-clause columns.
protected static void	EPServicesContextFactoryDefault.init(EventAdapterService eventAdapterService, ConfigurationInformation configSnapshot, EngineImportService engineImportService) Initialize event adapter service for config snapshot.
protected static ExceptionHandlingService	EPServicesContextFactoryDefault.initExceptionHandling(String engineURI, ConfigurationEngineDefaults.ExceptionHandling exceptionHandling, ConfigurationEngineDefaults.ConditionHandling conditionHandling, EngineImportService engineImportService)
protected static void	EPServicesContextFactoryDefault.initVariables(VariableService variableService, Map<String,ConfigurationVariable> variables, EngineImportService engineImportService) Adds configured variables to the variable service.
protected static DatabaseConfigService	EPServicesContextFactoryDefault.makeDatabaseRefService(ConfigurationInformation configSnapshot, SchedulingService schedulingService, SchedulingMgmtService schedulingMgmtService, EngineImportService engineImportService) Creates the database config service.

Constructors in com.espertech.esper.core.service with parameters of type EngineImportService

Constructor and Description
ConfigurationOperationsImpl(EventAdapterService eventAdapterService, EventTypeIdGenerator eventTypeIdGenerator, EngineImportService engineImportService, VariableService variableService, EngineSettingsService engineSettingsService, ValueAddEventService valueAddEventService, MetricReportingService metricReportingService, StatementEventTypeRef statementEventTypeRef, StatementVariableRef statementVariableRef, PluggableObjectCollection plugInViews, FilterService filterService, PatternSubexpressionPoolEngineSvc patternSubexpressionPoolSvc, MatchRecognizeStatePoolEngineSvc matchRecognizeStatePoolEngineSvc, TableService tableService, Map<String,Object> transientConfiguration)
EPServicesContext(String engineURI, SchedulingServiceSPI schedulingService, EventAdapterService eventAdapterService, EngineImportService engineImportService, EngineSettingsService engineSettingsService, DatabaseConfigService databaseConfigService, PluggableObjectCollection plugInViews, StatementLockFactory statementLockFactory, ManagedReadWriteLock eventProcessingRWLock, EngineLevelExtensionServicesContext engineLevelExtensionServicesContext, EngineEnvContext engineEnvContext, StatementContextFactory statementContextFactory, PluggableObjectCollection plugInPatternObjects, TimerService timerService, FilterServiceSPI filterService, StreamFactoryService streamFactoryService, NamedWindowMgmtService namedWindowMgmtService, NamedWindowDispatchService namedWindowDispatchService, VariableService variableService, TableService tableService, TimeSourceService timeSourceService, ValueAddEventService valueAddEventService, MetricReportingServiceSPI metricsReportingService, StatementEventTypeRef statementEventTypeRef, StatementVariableRef statementVariableRef, ConfigurationInformation configSnapshot, ThreadingService threadingServiceImpl, InternalEventRouterImpl internalEventRouter, StatementIsolationService statementIsolationService, SchedulingMgmtService schedulingMgmtService, DeploymentStateService deploymentStateService, ExceptionHandlingService exceptionHandlingService, PatternNodeFactory patternNodeFactory, EventTypeIdGenerator eventTypeIdGenerator, StatementMetadataFactory statementMetadataFactory, ContextManagementService contextManagementService, PatternSubexpressionPoolEngineSvc patternSubexpressionPoolSvc, MatchRecognizeStatePoolEngineSvc matchRecognizeStatePoolEngineSvc, DataFlowService dataFlowService, ExprDeclaredService exprDeclaredService, ContextControllerFactoryFactorySvc contextControllerFactoryFactorySvc, ContextManagerFactoryService contextManagerFactoryService, EPStatementFactory epStatementFactory, RegexHandlerFactory regexHandlerFactory, ViewableActivatorFactory viewableActivatorFactory, FilterNonPropertyRegisteryService filterNonPropertyRegisteryService, ResultSetProcessorHelperFactory resultSetProcessorHelperFactory, ViewServicePreviousFactory viewServicePreviousFactory, EventTableIndexService eventTableIndexService, EPRuntimeIsolatedFactory epRuntimeIsolatedFactory, FilterBooleanExpressionFactory filterBooleanExpressionFactory, DataCacheFactory dataCacheFactory, MultiMatchHandlerFactory multiMatchHandlerFactory, NamedWindowConsumerMgmtService namedWindowConsumerMgmtService, AggregationFactoryFactory aggregationFactoryFactory)
InternalEventRouterDesc(UpdateDesc updateDesc, EventBeanCopyMethod copyMethod, TypeWidener[] wideners, EventType eventType, Annotation[] annotations, EngineImportService engineImportService, String statementName)
InternalEventRouterImpl(String engineURI, EngineImportService engineImportService) Ctor.
ResultDeliveryStrategyImpl(EPStatement statement, Object subscriber, DeliveryConvertor deliveryConvertor, Method method, Method startMethod, Method endMethod, Method rStreamMethod, EngineImportService engineImportService) Ctor.
ResultDeliveryStrategyMap(EPStatement statement, Object subscriber, Method method, String[] columnNames, EngineImportService engineImportService) Ctor.
ResultDeliveryStrategyMapWStmt(EPStatement statement, Object subscriber, Method method, String[] columnNames, EngineImportService engineImportService)
ResultDeliveryStrategyObjectArr(EPStatement statement, Object subscriber, Method method, EngineImportService engineImportService) Ctor.
ResultDeliveryStrategyObjectArrWStmt(EPStatement statement, Object subscriber, Method method, EngineImportService engineImportService)
ResultDeliveryStrategyTypeArr(EPStatement statement, Object subscriber, Method method, Class componentType, EngineImportService engineImportService) Ctor.
ResultDeliveryStrategyTypeArrWStmt(EPStatement statement, Object subscriber, Method method, Class componentType, EngineImportService engineImportService)
StatementContextEngineServices(String engineURI, EventAdapterService eventAdapterService, NamedWindowMgmtService namedWindowMgmtService, VariableService variableService, TableService tableService, EngineSettingsService engineSettingsService, ValueAddEventService valueAddEventService, ConfigurationInformation configSnapshot, MetricReportingServiceSPI metricReportingService, ViewService viewService, ExceptionHandlingService exceptionHandlingService, ExpressionResultCacheService expressionResultCacheService, StatementEventTypeRef statementEventTypeRef, TableExprEvaluatorContext tableExprEvaluatorContext, EngineLevelExtensionServicesContext engineLevelExtensionServicesContext, RegexHandlerFactory regexHandlerFactory, StatementLockFactory statementLockFactory, ContextManagementService contextManagementService, ViewServicePreviousFactory viewServicePreviousFactory, EventTableIndexService eventTableIndexService, PatternNodeFactory patternNodeFactory, FilterBooleanExpressionFactory filterBooleanExpressionFactory, TimeSourceService timeSourceService, EngineImportService engineImportService, AggregationFactoryFactory aggregationFactoryFactory, SchedulingService schedulingService, ExprDeclaredService exprDeclaredService)

Uses of EngineImportService in com.espertech.esper.dataflow.core

Constructors in com.espertech.esper.dataflow.core with parameters of type EngineImportService

Constructor and Description
EPDataFlowEmitter1Stream1TargetBase(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, EngineImportService engineImportService)
EPDataFlowEmitter1Stream1TargetPassAlong(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, EngineImportService engineImportService)
EPDataFlowEmitter1Stream1TargetPassAlongWStream(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, int streamNum, EngineImportService engineImportService)
EPDataFlowEmitter1Stream1TargetUnwind(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, EngineImportService engineImportService)
EPDataFlowInstanceImpl(String engineURI, String statementName, boolean audit, String dataFlowName, Object userObject, String instanceId, EPDataFlowState state, List<GraphSourceRunnable> sourceRunnables, Map<Integer,Object> operators, Set<Integer> operatorBuildOrder, EPDataFlowInstanceStatistics statisticsProvider, Map<String,Object> parameters, EngineImportService engineImportService)
SignalHandlerDefaultWInvoke(Object target, Method method, EngineImportService engineImportService)
SignalHandlerDefaultWInvokeStream(Object target, Method method, EngineImportService engineImportService, int streamNum)

Uses of EngineImportService in com.espertech.esper.epl.agg.factory

Methods in com.espertech.esper.epl.agg.factory with parameters of type EngineImportService

Modifier and Type	Method and Description
AggregationAgent	AggregationMethodFactorySum.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryStddev.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryRate.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryPlugIn.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryNth.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryMinMax.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryMedian.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryLeaving.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryLastEver.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryFirstEver.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryCountEver.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryCount.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryAvg.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryAvedev.getAggregationStateAgent(EngineImportService engineImportService, String statementName)

Uses of EngineImportService in com.espertech.esper.epl.agg.service

Methods in com.espertech.esper.epl.agg.service with parameters of type EngineImportService

Modifier and Type	Method and Description
AggregationAgent	AggregationMethodFactory.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
static AggregationServiceFactoryDesc	AggregationServiceFactoryFactory.getService(List<ExprAggregateNode> selectAggregateExprNodes, Map<ExprNode,String> selectClauseNamedNodes, List<ExprDeclaredNode> declaredExpressions, ExprNode[] groupByNodes, List<ExprAggregateNode> havingAggregateExprNodes, List<ExprAggregateNode> orderByAggregateExprNodes, List<ExprAggregateNodeGroupKey> groupKeyExpressions, boolean hasGroupByClause, Annotation[] annotations, VariableService variableService, boolean isJoin, boolean isDisallowNoReclaim, ExprNode whereClause, ExprNode havingClause, AggregationServiceFactoryService factoryService, EventType[] typesPerStream, AggregationGroupByRollupDesc groupByRollupDesc, String optionalContextName, IntoTableSpec intoTableSpec, TableService tableService, boolean isUnidirectional, boolean isFireAndForget, boolean isOnSelect, EngineImportService engineImportService, String statementName)
static AggregationServiceMatchRecognizeFactoryDesc	AggregationServiceFactoryFactory.getServiceMatchRecognize(int numStreams, Map<Integer,List<ExprAggregateNode>> measureExprNodesPerStream, EventType[] typesPerStream, EngineImportService engineImportService, String statementName) Produces an aggregation service for use with match-recognice.
AggregationService	AggSvcGroupByWTableFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedWAccessRollupFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedWAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByRefcountedNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByReclaimAgedFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupByAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllNoAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllMixedAccessWTableFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllMixedAccessFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllLocalGroupByFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggSvcGroupAllAccessOnlyFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggregationServiceNullFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)
AggregationService	AggregationServiceFactory.makeService(AgentInstanceContext agentInstanceContext, EngineImportService engineImportService, boolean isSubquery, Integer subqueryNumber)

Uses of EngineImportService in com.espertech.esper.epl.agg.util

Methods in com.espertech.esper.epl.agg.util with parameters of type EngineImportService

Modifier and Type	Method and Description
static AggregationLocalGroupByPlan	AggregationGroupByLocalGroupByAnalyzer.analyze(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, AggregationStateFactory[] accessAggregations, AggregationGroupByLocalGroupDesc localGroupDesc, ExprNode[] groupByExpressions, AggregationAccessorSlotPair[] accessors, EngineImportService engineImportService, boolean fireAndForget, String statementName)

Uses of EngineImportService in com.espertech.esper.epl.annotation

Methods in com.espertech.esper.epl.annotation with parameters of type EngineImportService

Modifier and Type	Method and Description
static Annotation[]	AnnotationUtil.compileAnnotations(List<AnnotationDesc> annotationSpec, EngineImportService engineImportService, String eplStatement) Compile annotation objects from descriptors.

Uses of EngineImportService in com.espertech.esper.epl.core

Classes in com.espertech.esper.epl.core that implement EngineImportService

Modifier and Type	Class and Description
class	EngineImportServiceImpl Implementation for engine-level imports.

Methods in com.espertech.esper.epl.core with parameters of type EngineImportService

Modifier and Type	Method and Description
static SelectExprProcessor	SelectExprJoinWildcardProcessorFactory.create(Collection<Integer> assignedTypeNumberStack, int statementId, String statementName, String[] streamNames, EventType[] streamTypes, EventAdapterService eventAdapterService, InsertIntoDesc insertIntoDesc, SelectExprEventTypeRegistry selectExprEventTypeRegistry, EngineImportService engineImportService, Annotation[] annotations, ConfigurationInformation configuration, TableService tableService, String engineURI)
static HistoricalEventViewable	MethodPollingViewableFactory.createPollMethodView(int streamNumber, MethodStreamSpec methodStreamSpec, EventAdapterService eventAdapterService, EPStatementAgentInstanceHandle epStatementAgentInstanceHandle, EngineImportService engineImportService, SchedulingService schedulingService, ScheduleBucket scheduleBucket, ExprEvaluatorContext exprEvaluatorContext, VariableService variableService, String contextName, DataCacheFactory dataCacheFactory, StatementContext statementContext) Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache.
static SelectExprProcessor	SelectExprInsertEventBeanFactory.getInsertUnderlyingJoinWildcard(EventAdapterService eventAdapterService, EventType eventType, String[] streamNames, EventType[] streamTypes, EngineImportService engineImportService, String statementName, String engineURI)
static SelectExprProcessor	SelectExprInsertEventBeanFactory.getInsertUnderlyingNonJoin(EventAdapterService eventAdapterService, EventType eventType, boolean isUsingWildcard, StreamTypeService typeService, ExprEvaluator[] expressionNodes, ExprForge[] forges, String[] columnNames, Object[] expressionReturnTypes, EngineImportService engineImportService, InsertIntoDesc insertIntoDesc, String[] columnNamesAsProvided, boolean allowNestableTargetFragmentTypes, String statementName)
static SelectExprProcessor	SelectExprProcessorFactory.getProcessor(Collection<Integer> assignedTypeNumberStack, SelectClauseElementCompiled[] selectionList, boolean isUsingWildcard, InsertIntoDesc insertIntoDesc, EventType optionalInsertIntoEventType, ForClauseSpec forClauseSpec, StreamTypeService typeService, EventAdapterService eventAdapterService, StatementResultService statementResultService, ValueAddEventService valueAddEventService, SelectExprEventTypeRegistry selectExprEventTypeRegistry, EngineImportService engineImportService, ExprEvaluatorContext exprEvaluatorContext, VariableService variableService, TableService tableService, TimeProvider timeProvider, String engineURI, int statementId, String statementName, Annotation[] annotations, ContextDescriptor contextDescriptor, ConfigurationInformation configuration, SelectExprProcessorDeliveryCallback selectExprProcessorCallback, NamedWindowMgmtService namedWindowMgmtService, IntoTableSpec intoTableClause, com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo, StatementExtensionSvcContext statementExtensionSvcContext)
static OrderByProcessorFactory	OrderByProcessorFactoryFactory.getProcessor(List<SelectClauseExprCompiledSpec> selectionList, ExprEvaluator[] groupByNodeEvals, List<OrderByItem> orderByList, RowLimitSpec rowLimitSpec, VariableService variableService, boolean isSortUsingCollator, String optionalContextName, EngineImportService engineImportService, boolean onDemandQuery, String statementName) Returns processor for order-by clauses.
void	MethodPollingViewable.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, TimeProvider timeProvider, VariableService variableService, TableService tableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, String engineURI, Map<Integer,List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, StatementContext statementContext)

Constructors in com.espertech.esper.epl.core with parameters of type EngineImportService

Constructor and Description
BindProcessor(SelectClauseElementCompiled[] selectionList, EventType[] typesPerStream, String[] streamNames, TableService tableService, EngineImportService engineImportService, boolean isFireAndForget, Annotation[] annotations, String statementName) Ctor.
OrderByProcessorFactoryImpl(List<OrderByItem> orderByList, ExprEvaluator[] groupByEvals, boolean needsGroupByKeys, boolean isSortUsingCollator, EngineImportService engineImportService, boolean onDemandQuery, String statementName) Ctor.
SelectExprProcessorHelper(Collection<Integer> assignedTypeNumberStack, List<SelectClauseExprCompiledSpec> selectionList, List<SelectExprStreamDesc> selectedStreams, InsertIntoDesc insertIntoDesc, EventType optionalInsertIntoOverrideType, boolean isUsingWildcard, StreamTypeService typeService, EventAdapterService eventAdapterService, ValueAddEventService valueAddEventService, SelectExprEventTypeRegistry selectExprEventTypeRegistry, EngineImportService engineImportService, int statementId, String statementName, Annotation[] annotations, ConfigurationInformation configuration, NamedWindowMgmtService namedWindowMgmtService, TableService tableService, com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo)

Uses of EngineImportService in com.espertech.esper.epl.core.eval

Methods in com.espertech.esper.epl.core.eval with parameters of type EngineImportService

Modifier and Type	Method and Description
static SelectExprProcessor	EvalSelectStreamWUndRecastObjectArrayFactory.make(EventType[] eventTypes, SelectExprContext selectExprContext, int streamNumber, EventType targetType, ExprNode[] exprNodes, EngineImportService engineImportService, String statementName, String engineURI)
static SelectExprProcessor	EvalSelectStreamWUndRecastMapFactory.make(EventType[] eventTypes, SelectExprContext selectExprContext, int streamNumber, EventType targetType, ExprNode[] exprNodes, EngineImportService engineImportService, String statementName, String engineURI)

Uses of EngineImportService in com.espertech.esper.epl.db

Methods in com.espertech.esper.epl.db with parameters of type EngineImportService

Modifier and Type

Method and Description

void

DatabasePollingViewable.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, TimeProvider timeProvider, VariableService variableService, TableService tableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, String engineURI, Map<Integer,List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, StatementContext statementContext)

Constructors in com.espertech.esper.epl.db with parameters of type EngineImportService

Constructor and Description
DatabaseConfigServiceImpl(Map<String,ConfigurationDBRef> mapDatabaseRef, SchedulingService schedulingService, ScheduleBucket scheduleBucket, EngineImportService engineImportService) Ctor.
DatabaseDMConnFactory(ConfigurationDBRef.DriverManagerConnection driverConfig, ConfigurationDBRef.ConnectionSettings connectionSettings, EngineImportService engineImportService) Ctor.
DatabaseDSFactoryConnFactory(ConfigurationDBRef.DataSourceFactory dsConfig, ConfigurationDBRef.ConnectionSettings connectionSettings, EngineImportService engineImportService) Ctor.

Uses of EngineImportService in com.espertech.esper.epl.enummethod.dot

Methods in com.espertech.esper.epl.enummethod.dot with parameters of type EngineImportService

Modifier and Type	Method and Description
abstract EnumForge	ExprDotForgeEnumMethodBase.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)

Uses of EngineImportService in com.espertech.esper.epl.enummethod.eval

Methods in com.espertech.esper.epl.enummethod.eval with parameters of type EngineImportService

Modifier and Type	Method and Description
EnumForge	ExprDotForgeWhere.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeToMap.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeTakeWhileAndLast.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeTakeAndTakeLast.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeSumOf.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeSetExceptUnionIntersect.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeSequenceEqual.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeSelectFrom.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeReverse.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeOrderByAscDesc.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeNoOp.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeMostLeastFrequent.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeMinMax.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeMinByMaxBy.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeGroupBy.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeFirstLastOf.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeDistinct.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeCountOf.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeAverage.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeAllOfAnyOf.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)
EnumForge	ExprDotForgeAggregate.getEnumForge(EngineImportService engineImportService, EventAdapterService eventAdapterService, StreamTypeService streamTypeService, int statementId, String enumMethodUsedName, List<ExprDotEvalParam> bodiesAndParameters, EventType inputEventType, Class collectionComponentType, int numStreamsIncoming, boolean disablePropertyExpressionEventCollCache)

Uses of EngineImportService in com.espertech.esper.epl.expression.accessagg

Methods in com.espertech.esper.epl.expression.accessagg with parameters of type EngineImportService

Modifier and Type	Method and Description
AggregationAgent	ExprPlugInAggMultiFunctionNodeFactory.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	ExprAggMultiFunctionSortedMinMaxByNodeFactory.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	ExprAggMultiFunctionLinearAccessNodeFactoryAccess.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	ExprAggCountMinSketchNodeFactoryUse.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	ExprAggCountMinSketchNodeFactoryState.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationAgent	AggregationMethodFactoryFirstLastUnbound.getAggregationStateAgent(EngineImportService engineImportService, String statementName)
static AggregationAgent	ExprAggAggregationAgentFactory.make(int streamNum, ExprNode optionalFilter, EngineImportService engineImportService, boolean isFireAndForget, String statementName)

Constructors in com.espertech.esper.epl.expression.accessagg with parameters of type EngineImportService

Constructor and Description
SortedAggregationStateFactoryFactory(EngineImportService engineImportService, StatementExtensionSvcContext statementExtensionSvcContext, ExprNode[] expressions, ExprEvaluator[] evaluators, boolean[] sortDescending, boolean ever, int streamNum, ExprAggMultiFunctionSortedMinMaxByNode parent, ExprEvaluator optionalFilter)

Uses of EngineImportService in com.espertech.esper.epl.expression.core

Methods in com.espertech.esper.epl.expression.core that return EngineImportService

Modifier and Type	Method and Description
EngineImportService	ExprValidationContext.getEngineImportService()

Methods in com.espertech.esper.epl.expression.core with parameters of type EngineImportService

Modifier and Type	Method and Description
static ExprEvaluator	ExprNodeCompiler.allocateEvaluator(ExprForge forge, EngineImportService engineImportService, Class compiledByClass, boolean onDemandQuery, String statementName)
static ExprEvaluator[]	ExprNodeUtility.getEvaluatorsMayCompile(ExprForge[] forges, EngineImportService engineImportService, Class requestor, boolean isFireAndForget, String statementName)
static ExprEvaluator[]	ExprNodeUtility.getEvaluatorsMayCompile(ExprNode[] exprNodes, EngineImportService engineImportService, Class requestor, boolean isFireAndForget, String statementName)
static ExprEvaluator[]	ExprNodeUtility.getEvaluatorsMayCompile(List<ExprNode> exprNodes, EngineImportService engineImportService, Class requestor, boolean isFireAndForget, String statementName)
static ExprNodeUtilMethodDesc	ExprNodeUtility.resolveMethodAllowWildcardAndStream(String className, Class optionalClass, String methodName, List<ExprNode> parameters, EngineImportService engineImportService, EventAdapterService eventAdapterService, int statementId, boolean allowWildcard, EventType wildcardType, ExprNodeUtilResolveExceptionHandler exceptionHandler, String functionName, TableService tableService, String engineURI)

Constructors in com.espertech.esper.epl.expression.core with parameters of type EngineImportService

Constructor and Description

ExprValidationContext(StreamTypeService streamTypeService, EngineImportService engineImportService, StatementExtensionSvcContext statementExtensionSvcContext, ViewResourceDelegateUnverified viewResourceDelegate, TimeProvider timeProvider, VariableService variableService, TableService tableService, ExprEvaluatorContext exprEvaluatorContext, EventAdapterService eventAdapterService, String statementName, int statementId, Annotation[] annotations, ContextDescriptor contextDescriptor, boolean disablePropertyExpressionEventCollCache, boolean allowRollupFunctions, boolean allowBindingConsumption, boolean isUnidirectionalJoin, String intoTableName, boolean isFilterExpression)

Uses of EngineImportService in com.espertech.esper.epl.expression.dot

Methods in com.espertech.esper.epl.expression.dot that return EngineImportService

Modifier and Type	Method and Description
EngineImportService	ExprDotMethodForgeDuck.getEngineImportService()

Constructors in com.espertech.esper.epl.expression.dot with parameters of type EngineImportService

Constructor and Description
ExprDotMethodForgeDuck(String statementName, EngineImportService engineImportService, String methodName, Class[] parameterTypes, ExprForge[] parameters)

Uses of EngineImportService in com.espertech.esper.epl.expression.subquery

Methods in com.espertech.esper.epl.expression.subquery with parameters of type EngineImportService

Modifier and Type	Method and Description
static SubselectEvalStrategyNR	SubselectEvalStrategyNRFactory.createStrategyAnyAllIn(ExprSubselectNode subselectExpression, boolean isNot, boolean isAll, boolean isAny, RelationalOpEnum relationalOp, EngineImportService engineImportService, String statementName)
void	ExprSubselectNode.setSelectClause(ExprNode[] selectClause, EngineImportService engineImportService, String statementName) Sets the validates select clause

Uses of EngineImportService in com.espertech.esper.epl.join.base

Constructors in com.espertech.esper.epl.join.base with parameters of type EngineImportService

Constructor and Description

JoinSetComposerPrototypeImpl(String statementName, int statementId, OuterJoinDesc[] outerJoinDescList, ExprNode optionalFilterNode, EventType[] streamTypes, String[] streamNames, StreamJoinAnalysisResult streamJoinAnalysisResult, Annotation[] annotations, HistoricalViewableDesc historicalViewableDesc, ExprEvaluatorContext exprEvaluatorContext, QueryPlanIndex[] indexSpecs, QueryPlan queryPlan, HistoricalStreamIndexList[] historicalStreamIndexLists, boolean joinRemoveStream, boolean isOuterJoins, TableService tableService, EventTableIndexService eventTableIndexService, EngineImportService engineImportService, boolean isFireAndForget)

Uses of EngineImportService in com.espertech.esper.epl.join.plan

Methods in com.espertech.esper.epl.join.plan with parameters of type EngineImportService

Modifier and Type	Method and Description
protected static QueryPlan	NStreamOuterQueryPlanBuilder.build(QueryGraph queryGraph, OuterJoinDesc[] outerJoinDescList, String[] streamNames, EventType[] typesPerStream, HistoricalViewableDesc historicalViewableDesc, DependencyGraph dependencyGraph, HistoricalStreamIndexList[] historicalStreamIndexLists, ExprEvaluatorContext exprEvaluatorContext, String[][][] indexedStreamsUniqueProps, TableMetadata[] tablesPerStream, EngineImportService engineImportService, boolean isFireAndForget) Build a query plan based on the stream property relationships indicated in queryGraph.
static QueryPlan	QueryPlanBuilder.getPlan(EventType[] typesPerStream, OuterJoinDesc[] outerJoinDescList, QueryGraph queryGraph, String[] streamNames, HistoricalViewableDesc historicalViewableDesc, DependencyGraph dependencyGraph, HistoricalStreamIndexList[] historicalStreamIndexLists, StreamJoinAnalysisResult streamJoinAnalysisResult, boolean isQueryPlanLogging, Annotation[] annotations, ExprEvaluatorContext exprEvaluatorContext, EngineImportService engineImportService, boolean isFireAndForget) Build query plan using the filter.

Uses of EngineImportService in com.espertech.esper.epl.join.util

Methods in com.espertech.esper.epl.join.util with parameters of type EngineImportService

Modifier and Type	Method and Description
static QueryPlanIndexHook	QueryPlanIndexHookUtil.getHook(Annotation[] annotations, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.epl.lookup

Methods in com.espertech.esper.epl.lookup with parameters of type EngineImportService

Modifier and Type	Method and Description
static SubordinateWMatchExprQueryPlanResult	SubordinateQueryPlanner.planOnExpression(ExprNode joinExpr, EventType filterEventType, IndexHint optionalIndexHint, boolean isIndexShare, int subqueryNumber, ExcludePlanHint excludePlanHint, boolean isVirtualDataWindow, EventTableIndexMetadata indexMetadata, EventType eventTypeIndexed, Set<String> optionalUniqueKeyProps, boolean onlyUseExistingIndexes, String statementName, int statementId, Annotation[] annotations, EngineImportService engineImportService)
static void	SubordinateQueryPlannerUtil.queryPlanLogOnExpr(boolean queryPlanLogging, org.slf4j.Logger queryPlanLog, SubordinateWMatchExprQueryPlanResult strategy, Annotation[] annotations, EngineImportService engineImportService)
static void	SubordinateQueryPlannerUtil.queryPlanLogOnSubq(boolean queryPlanLogging, org.slf4j.Logger queryPlanLog, SubordinateQueryPlanDesc plan, int subqueryNum, Annotation[] annotations, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.epl.named

Constructors in com.espertech.esper.epl.named with parameters of type EngineImportService

Constructor and Description
NamedWindowOnMergeMatch(ExprNode optionalCond, List<NamedWindowOnMergeAction> actions, EngineImportService engineImportService, String statementName)

Uses of EngineImportService in com.espertech.esper.epl.parse

Methods in com.espertech.esper.epl.parse with parameters of type EngineImportService

Modifier and Type	Method and Description
static Pair<ExprTableAccessNode,List<ExprChainedSpec>>	ASTTableExprHelper.checkTableNameGetLibFunc(TableService tableService, EngineImportService engineImportService, LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations, String engineURI, String classIdent, List<ExprChainedSpec> chain)
static List<CreateTableColumn>	ASTTableHelper.getColumns(List<EsperEPL2GrammarParser.CreateTableColumnContext> ctxs, Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap, EngineImportService engineImportService)
static Pair<ExprTableAccessNode,List<ExprChainedSpec>>	ASTTableExprHelper.getTableExprChainable(EngineImportService engineImportService, LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations, String engineURI, String tableName, List<ExprChainedSpec> chain)
static void	ASTLibFunctionHelper.handleLibFunc(org.antlr.v4.runtime.CommonTokenStream tokenStream, EsperEPL2GrammarParser.LibFunctionContext ctx, ConfigurationInformation configurationInformation, EngineImportService engineImportService, Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap, LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations, String engineURI, ExpressionDeclDesc expressionDeclarations, ExprDeclaredService exprDeclaredService, List<ExpressionScriptProvided> scriptExpressions, ContextDescriptor contextDescriptor, TableService tableService, StatementSpecRaw statementSpec, VariableService variableService)
static ExprNode	ASTAggregationHelper.tryResolveAsAggregation(EngineImportService engineImportService, boolean distinct, String functionName, LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations, String engineURI)
static AnnotationDesc	ASTAnnotationHelper.walk(EsperEPL2GrammarParser.AnnotationEnumContext ctx, EngineImportService engineImportService) Walk an annotation root name or child node (nested annotations).
static CreateDataFlowDesc	ASTGraphHelper.walkCreateDataFlow(EsperEPL2GrammarParser.CreateDataflowContext ctx, Map<org.antlr.v4.runtime.tree.Tree,Object> astGraphNodeMap, EngineImportService engineImportService)

Constructors in com.espertech.esper.epl.parse with parameters of type EngineImportService

Constructor and Description

EPLTreeWalkerListener(org.antlr.v4.runtime.CommonTokenStream tokenStream, EngineImportService engineImportService, VariableService variableService, SchedulingService schedulingService, SelectClauseStreamSelectorEnum defaultStreamSelector, String engineURI, ConfigurationInformation configurationInformation, PatternNodeFactory patternNodeFactory, ContextManagementService contextManagementService, List<String> scriptBodies, ExprDeclaredService exprDeclaredService, TableService tableService)

Uses of EngineImportService in com.espertech.esper.epl.property

Methods in com.espertech.esper.epl.property with parameters of type EngineImportService

Modifier and Type

Method and Description

static PropertyEvaluator

PropertyEvaluatorFactory.makeEvaluator(PropertyEvalSpec spec, EventType sourceEventType, String optionalSourceStreamName, EventAdapterService eventAdapterService, EngineImportService engineImportService, TimeProvider timeProvider, VariableService variableService, TableService tableService, String engineURI, int statementId, String statementName, Annotation[] annotations, Collection<Integer> assignedTypeNumberStack, ConfigurationInformation configuration, NamedWindowMgmtService namedWindowMgmtService, StatementExtensionSvcContext statementExtensionSvcContext)

Uses of EngineImportService in com.espertech.esper.epl.script.mvel

Methods in com.espertech.esper.epl.script.mvel with parameters of type EngineImportService

Modifier and Type	Method and Description
static void	MVELInvoker.analysisCompile(String expression, Object parserContext, EngineImportService engineImportService)
static ExpressionScriptCompiled	MVELHelper.compile(String scriptName, String expression, Map<String,Class> mvelInputParamTypes, EngineImportService engineImportService)
static boolean	MVELInvoker.isMVELInClasspath(EngineImportService engineImportService)
static Object	MVELInvoker.newParserContext(EngineImportService engineImportService)
static void	MVELHelper.verifyScript(ExpressionScriptProvided script, EngineImportService engineImportService) Verify MVEL script (not compiling it).

Uses of EngineImportService in com.espertech.esper.epl.spec

Methods in com.espertech.esper.epl.spec that return EngineImportService

Modifier and Type	Method and Description
EngineImportService	StatementSpecMapContext.getEngineImportService() Returns the engine import service.

Methods in com.espertech.esper.epl.spec with parameters of type EngineImportService

Modifier and Type	Method and Description
void	PluggableObjectCollection.addPatternObjects(List<ConfigurationPlugInPatternObject> configPattern, EngineImportService engineImportService) Add a plug-in pattern object.
void	PluggableObjectCollection.addViews(List<ConfigurationPlugInView> configurationPlugInViews, List<ConfigurationPlugInVirtualDataWindow> configurationPlugInVirtualDW, EngineImportService engineImportService) Add a plug-in view.
static StatementSpecRaw	StatementSpecMapper.map(EPStatementObjectModel sodaStatement, EngineImportService engineImportService, VariableService variableService, ConfigurationInformation configuration, SchedulingService schedulingService, String engineURI, PatternNodeFactory patternNodeFactory, NamedWindowMgmtService namedWindowMgmtService, ContextManagementService contextManagementService, ExprDeclaredService exprDeclaredService, TableService tableService)

Constructors in com.espertech.esper.epl.spec with parameters of type EngineImportService

Constructor and Description

StatementSpecMapContext(EngineImportService engineImportService, VariableService variableService, ConfigurationInformation configuration, SchedulingService schedulingService, String engineURI, PatternNodeFactory patternNodeFactory, NamedWindowMgmtService namedWindowMgmtService, ContextManagementService contextManagementService, ExprDeclaredService exprDeclaredService, ContextDescriptor contextDescriptor, TableService tableService)

Uses of EngineImportService in com.espertech.esper.epl.table.merge

Constructors in com.espertech.esper.epl.table.merge with parameters of type EngineImportService

Constructor and Description
TableOnMergeMatch(ExprNode optionalCond, List<TableOnMergeAction> actions, EngineImportService engineImportService, String statementName)

Uses of EngineImportService in com.espertech.esper.epl.table.mgmt

Methods in com.espertech.esper.epl.table.mgmt with parameters of type EngineImportService

Modifier and Type	Method and Description
Pair<ExprNode,List<ExprChainedSpec>>	TableServiceImpl.getTableNodeChainable(StreamTypeService streamTypeService, List<ExprChainedSpec> chainSpec, EngineImportService engineImportService)
Pair<ExprNode,List<ExprChainedSpec>>	TableService.getTableNodeChainable(StreamTypeService streamTypeService, List<ExprChainedSpec> chainSpec, EngineImportService engineImportService)

Constructors in com.espertech.esper.epl.table.mgmt with parameters of type EngineImportService

Constructor and Description
TableStateRowFactory(ObjectArrayEventType objectArrayEventType, EngineImportService engineImportService, AggregationMethodFactory[] methodFactories, AggregationStateFactory[] stateFactories, int[] groupKeyIndexes, EventAdapterService eventAdapterService)

Uses of EngineImportService in com.espertech.esper.epl.variable

Methods in com.espertech.esper.epl.variable with parameters of type EngineImportService

Modifier and Type	Method and Description
void	VariableServiceImpl.createNewVariable(String optionalContextName, String variableName, String variableType, boolean constant, boolean array, boolean arrayOfPrimitive, Object value, EngineImportService engineImportService)
void	VariableService.createNewVariable(String optionalContextName, String variableName, String type, boolean constant, boolean array, boolean arrayOfPrimitive, Object value, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.event

Methods in com.espertech.esper.event that return EngineImportService

Modifier and Type	Method and Description
EngineImportService	EventAdapterServiceImpl.getEngineImportService()
EngineImportService	EventAdapterService.getEngineImportService()

Methods in com.espertech.esper.event with parameters of type EngineImportService

Modifier and Type	Method and Description
static Object	EventTypeUtility.buildType(ColumnDesc column, EngineImportService engineImportService)
static LinkedHashMap<String,Object>	EventTypeUtility.buildType(List<ColumnDesc> columns, EventAdapterService eventAdapterService, Set<String> copyFrom, EngineImportService engineImportService)
static EventType	EventTypeUtility.createNonVariantType(boolean isAnonymous, CreateSchemaDesc spec, Annotation[] annotations, ConfigurationInformation configSnapshot, EventAdapterService eventAdapterService, EngineImportService engineImportService)
static EventBeanManufacturer	EventAdapterServiceHelper.getManufacturer(EventAdapterService eventAdapterService, EventType eventType, WriteablePropertyDescriptor[] properties, EngineImportService engineImportService, boolean allowAnyType, EventAdapterAvroHandler avroHandler) Returns a factory for creating and populating event object instances for the given type.
EventBeanManufacturer	EventAdapterServiceImpl.getManufacturer(EventType eventType, WriteablePropertyDescriptor[] properties, EngineImportService engineImportService, boolean allowAnyType)
EventBeanManufacturer	EventAdapterService.getManufacturer(EventType eventType, WriteablePropertyDescriptor[] properties, EngineImportService engineImportService, boolean allowAnyType) Returns a factory for creating and populating event object instances for the given type.

Constructors in com.espertech.esper.event with parameters of type EngineImportService

Constructor and Description
EventAdapterServiceImpl(EventTypeIdGenerator eventTypeIdGenerator, int anonymousTypeCacheSize, EventAdapterAvroHandler avroHandler, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.event.avro

Methods in com.espertech.esper.event.avro with parameters of type EngineImportService

Modifier and Type	Method and Description
void	EventAdapterAvroHandlerUnsupported.init(ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings, EngineImportService engineImportService)
void	EventAdapterAvroHandler.init(ConfigurationEngineDefaults.EventMeta.AvroSettings avroSettings, EngineImportService engineImportService)

Uses of EngineImportService in com.espertech.esper.event.bean

Methods in com.espertech.esper.event.bean with parameters of type EngineImportService

Modifier and Type	Method and Description
static Pair<net.sf.cglib.reflect.FastConstructor,ExprForge[]>	InstanceManufacturerUtil.getManufacturer(Class targetClass, EngineImportService engineImportService, ExprForge[] exprForges, Object[] expressionReturnTypes)
static InstanceManufacturerFactory	InstanceManufacturerFactoryFactory.getManufacturer(Class targetClass, EngineImportService engineImportService, ExprNode[] childNodes)
static BeanInstantiator	BeanInstantiatorFactory.makeInstantiator(BeanEventType beanEventType, EngineImportService engineImportService)

Constructors in com.espertech.esper.event.bean with parameters of type EngineImportService

Constructor and Description
EventBeanManufacturerBean(BeanEventType beanEventType, EventAdapterService service, WriteablePropertyDescriptor[] properties, EngineImportService engineImportService) Ctor.

Uses of EngineImportService in com.espertech.esper.event.xml

Methods in com.espertech.esper.event.xml with parameters of type EngineImportService

Modifier and Type	Method and Description
static SchemaModel	XSDSchemaMapper.loadAndMap(String schemaResource, String schemaText, EngineImportService engineImportService) Loading and mapping of the schema to the internal representation.

Uses of EngineImportService in com.espertech.esper.filter

Fields in com.espertech.esper.filter declared as EngineImportService

Modifier and Type	Field and Description
EngineImportService	FilterSpecCompilerArgs.engineImportService

Methods in com.espertech.esper.filter with parameters of type EngineImportService

Modifier and Type	Method and Description
static FilterSpecCompiled	FilterSpecCompiler.buildNoStmtCtx(List<ExprNode> validatedFilterNodes, EventType eventType, String eventTypeName, PropertyEvalSpec optionalPropertyEvalSpec, LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes, StreamTypeService streamTypeService, String optionalStreamName, Collection<Integer> assignedTypeNumberStack, ExprEvaluatorContext exprEvaluatorContext, int statementId, String statementName, Annotation[] annotations, ContextDescriptor contextDescriptor, EngineImportService engineImportService, EventAdapterService eventAdapterService, FilterBooleanExpressionFactory filterBooleanExpressionFactory, TimeProvider timeProvider, VariableService variableService, TableService tableService, ConfigurationInformation configurationInformation, NamedWindowMgmtService namedWindowMgmtService, StatementExtensionSvcContext statementExtensionSvcContext)
protected ExprNodeAdapterBase	FilterBooleanExpressionFactoryImpl.getLockableMultiStream(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext exprEvaluatorContext, VariableService variableServiceToUse, EngineImportService engineImportService, EventBean[] events, Annotation[] annotations)
protected ExprNodeAdapterBase	FilterBooleanExpressionFactoryImpl.getLockableMultiStreamNoTL(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext exprEvaluatorContext, VariableService variableServiceToUse, EngineImportService engineImportService, EventBean[] events, Annotation[] annotations)

Constructors in com.espertech.esper.filter with parameters of type EngineImportService

Constructor and Description
ExprNodeAdapterBase(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, EngineImportService engineImportService, Annotation[] annotations)
ExprNodeAdapterBaseStmtLock(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, Annotation[] annotations)
ExprNodeAdapterBaseVariables(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, Annotation[] annotations)
ExprNodeAdapterBaseWTableAccess(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, ExprNodeAdapterBase evalBase, TableService tableService, EngineImportService engineImportService, Annotation[] annotations)
ExprNodeAdapterMultiStream(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, EventBean[] prototype, Annotation[] annotations)
ExprNodeAdapterMultiStreamNoTL(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, EventBean[] prototype, Annotation[] annotations)
ExprNodeAdapterMultiStreamNoTLStmtLock(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, EventBean[] prototype, Annotation[] annotations)
ExprNodeAdapterMultiStreamStmtLock(int filterSpecId, int filterSpecParamPathNum, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EngineImportService engineImportService, EventBean[] prototype, Annotation[] annotations)
FilterSpecCompilerArgs(LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes, LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes, ExprEvaluatorContext exprEvaluatorContext, String statementName, int statementId, StreamTypeService streamTypeService, EngineImportService engineImportService, TimeProvider timeProvider, VariableService variableService, TableService tableService, EventAdapterService eventAdapterService, FilterBooleanExpressionFactory filterBooleanExpressionFactory, Annotation[] annotations, ContextDescriptor contextDescriptor, ConfigurationInformation configurationInformation, StatementExtensionSvcContext statementExtensionSvcContext)

Uses of EngineImportService in com.espertech.esper.pattern

Methods in com.espertech.esper.pattern with parameters of type EngineImportService

Modifier and Type	Method and Description
void	EvalEveryDistinctFactoryNode.setDistinctExpressions(List<ExprNode> distinctExpressions, ExprTimePeriodEvalDeltaConst timeDeltaComputation, ExprNode expiryTimeExp, EngineImportService engineImportService, String statementName)

Uses of EngineImportService in com.espertech.esper.util

Methods in com.espertech.esper.util with parameters of type EngineImportService

Modifier and Type	Method and Description
static Object	JavaClassHelper.getAnnotationHook(Annotation[] annotations, HookType hookType, Class interfaceExpected, EngineImportService engineImportService) Returns an instance of a hook as specified by an annotation.
static Object	JavaClassHelper.resolveIdentAsEnumConst(String constant, EngineImportService engineImportService, boolean isAnnotation) Resolve a string constant as a possible enumeration value, returning null if not resolved.

Uses of EngineImportService in com.espertech.esper.view

Methods in com.espertech.esper.view with parameters of type EngineImportService

Modifier and Type

Method and Description

void

ValidatedView.validate(EngineImportService engineImportService, StreamTypeService streamTypeService, TimeProvider timeProvider, VariableService variableService, TableService tableService, ExprEvaluatorContext exprEvaluatorContext, ConfigurationInformation configSnapshot, SchedulingService schedulingService, String engineURI, Map<Integer,List<ExprNode>> sqlParameters, EventAdapterService eventAdapterService, StatementContext statementContext) Validate the view.

Uses of EngineImportService in com.espertech.esper.view.stat

Methods in com.espertech.esper.view.stat with parameters of type EngineImportService

Modifier and Type	Method and Description
static StatViewAdditionalProps	StatViewAdditionalProps.make(ExprNode[] validated, int startIndex, EventType parentEventType, EngineImportService engineImportService, String statementName)