|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EngineImportService | |
---|---|
com.espertech.esper.core.context.mgr | Context management. |
com.espertech.esper.core.service | Implementation of client package interfaces, glue code |
com.espertech.esper.epl.agg.service | Aggregation services. |
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.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.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.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.bean | JavaBean and legacy Java underlying event classes are here. |
com.espertech.esper.filter | Main switchboard filtering and routing of incoming events to interested statements is performed in this package. |
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. |
Uses of EngineImportService in com.espertech.esper.core.context.mgr |
---|
Constructors in com.espertech.esper.core.context.mgr with parameters of type EngineImportService | |
---|---|
ContextControllerHashedGetterSingleRow(java.lang.String statementName,
java.lang.String functionName,
Pair<java.lang.Class,EngineImportSingleRowDesc> func,
java.util.List<ExprNode> parameters,
int granularity,
EngineImportService engineImportService,
EventType eventType,
EventAdapterService eventAdapterService,
int statementId,
TableService tableService)
|
Uses of EngineImportService in com.espertech.esper.core.service |
---|
Methods in com.espertech.esper.core.service that return EngineImportService | |
---|---|
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)
Constructs the auto import service. |
Methods in com.espertech.esper.core.service with parameters of type EngineImportService | |
---|---|
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(java.lang.String eplStatement,
java.lang.String eplStatementForErrorMsg,
boolean addPleaseCheck,
java.lang.String statementName,
SelectClauseStreamSelectorEnum defaultStreamSelector,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
java.lang.String engineURI,
ConfigurationInformation configSnapshot,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService)
Compile the EPL. |
protected static void |
EPServicesContextFactoryDefault.initVariables(VariableService variableService,
java.util.Map<java.lang.String,ConfigurationVariable> variables,
EngineImportService engineImportService)
Adds configured variables to the variable service. |
Constructors in com.espertech.esper.core.service with parameters of type EngineImportService | |
---|---|
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)
Ctor. |
|
EPServicesContext(java.lang.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)
Constructor - sets up new set of services. |
|
StatementContextEngineServices(java.lang.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)
|
Uses of EngineImportService in com.espertech.esper.epl.agg.service |
---|
Methods in com.espertech.esper.epl.agg.service with parameters of type EngineImportService | |
---|---|
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)
|
Uses of EngineImportService in com.espertech.esper.epl.annotation |
---|
Methods in com.espertech.esper.epl.annotation with parameters of type EngineImportService | |
---|---|
static java.lang.annotation.Annotation[] |
AnnotationUtil.compileAnnotations(java.util.List<AnnotationDesc> annotationSpec,
EngineImportService engineImportService,
java.lang.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 | |
---|---|
class |
EngineImportServiceImpl
Implementation for engine-level imports. |
Methods in com.espertech.esper.epl.core with parameters of type EngineImportService | |
---|---|
static SelectExprProcessor |
SelectExprJoinWildcardProcessorFactory.create(java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
int statementId,
java.lang.String[] streamNames,
EventType[] streamTypes,
EventAdapterService eventAdapterService,
InsertIntoDesc insertIntoDesc,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
java.lang.annotation.Annotation[] annotations,
ConfigurationInformation configuration,
TableService tableService)
Ctor. |
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
java.lang.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,
java.lang.String[] streamNames,
EventType[] streamTypes,
EngineImportService engineImportService)
|
static SelectExprProcessor |
SelectExprInsertEventBeanFactory.getInsertUnderlyingNonJoin(EventAdapterService eventAdapterService,
EventType eventType,
boolean isUsingWildcard,
StreamTypeService typeService,
ExprEvaluator[] expressionNodes,
java.lang.String[] columnNames,
java.lang.Object[] expressionReturnTypes,
EngineImportService engineImportService,
InsertIntoDesc insertIntoDesc,
java.lang.String[] columnNamesAsProvided,
boolean allowNestableTargetFragmentTypes)
|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(java.util.Collection<java.lang.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,
java.lang.String engineURI,
int statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowMgmtService namedWindowMgmtService,
IntoTableSpec intoTableClause,
com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo,
StatementExtensionSvcContext statementExtensionSvcContext)
Returns the processor to use for a given select-clause. |
void |
MethodPollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
|
Constructors in com.espertech.esper.epl.core with parameters of type EngineImportService | |
---|---|
SelectExprProcessorHelper(java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
java.util.List<SelectClauseExprCompiledSpec> selectionList,
java.util.List<SelectExprStreamDesc> selectedStreams,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoOverrideType,
boolean isUsingWildcard,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
int statementId,
java.lang.annotation.Annotation[] annotations,
ConfigurationInformation configuration,
NamedWindowMgmtService namedWindowMgmtService,
TableService tableService,
com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo)
Ctor. |
Uses of EngineImportService in com.espertech.esper.epl.core.eval |
---|
Methods in com.espertech.esper.epl.core.eval with parameters of type EngineImportService | |
---|---|
static SelectExprProcessor |
EvalSelectStreamWUndRecastObjectArrayFactory.make(EventType[] eventTypes,
SelectExprContext selectExprContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService)
|
static SelectExprProcessor |
EvalSelectStreamWUndRecastMapFactory.make(EventType[] eventTypes,
SelectExprContext selectExprContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService)
|
Uses of EngineImportService in com.espertech.esper.epl.db |
---|
Methods in com.espertech.esper.epl.db with parameters of type EngineImportService | |
---|---|
void |
DatabasePollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
|
Uses of EngineImportService in com.espertech.esper.epl.enummethod.dot |
---|
Methods in com.espertech.esper.epl.enummethod.dot with parameters of type EngineImportService | |
---|---|
abstract EnumEval |
ExprDotEvalEnumMethodBase.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.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 | |
---|---|
EnumEval |
ExprDotEvalWhere.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalToMap.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalTakeWhileAndLast.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalTakeAndTakeLast.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalSumOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalSetExceptUnionIntersect.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalSequenceEqual.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalSelectFrom.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalReverse.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalOrderByAscDesc.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalNoOp.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalMostLeastFrequent.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalMinMax.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalMinByMaxBy.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalGroupBy.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalFirstLastOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalDistinct.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalCountOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalAverage.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalAllOfAnyOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
EnumEval |
ExprDotEvalAggregate.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
java.lang.String enumMethodUsedName,
java.util.List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
java.lang.Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache)
|
Uses of EngineImportService in com.espertech.esper.epl.expression.accessagg |
---|
Constructors in com.espertech.esper.epl.expression.accessagg with parameters of type EngineImportService | |
---|---|
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent)
|
Uses of EngineImportService in com.espertech.esper.epl.expression.core |
---|
Methods in com.espertech.esper.epl.expression.core that return EngineImportService | |
---|---|
EngineImportService |
ExprValidationContext.getEngineImportService()
|
Methods in com.espertech.esper.epl.expression.core with parameters of type EngineImportService | |
---|---|
static ExprNodeUtilMethodDesc |
ExprNodeUtility.resolveMethodAllowWildcardAndStream(java.lang.String className,
java.lang.Class optionalClass,
java.lang.String methodName,
java.util.List<ExprNode> parameters,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
int statementId,
boolean allowWildcard,
EventType wildcardType,
ExprNodeUtilResolveExceptionHandler exceptionHandler,
java.lang.String functionName,
TableService tableService)
|
Constructors in com.espertech.esper.epl.expression.core with parameters of type EngineImportService | |
---|---|
ExprValidationContext(StreamTypeService streamTypeService,
EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ViewResourceDelegateUnverified viewResourceDelegate,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
EventAdapterService eventAdapterService,
java.lang.String statementName,
int statementId,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
boolean disablePropertyExpressionEventCollCache,
boolean allowRollupFunctions,
boolean allowBindingConsumption,
boolean isUnidirectionalJoin,
java.lang.String intoTableName,
boolean isFilterExpression)
|
Uses of EngineImportService in com.espertech.esper.epl.expression.dot |
---|
Constructors in com.espertech.esper.epl.expression.dot with parameters of type EngineImportService | |
---|---|
ExprDotMethodEvalDuck(java.lang.String statementName,
EngineImportService engineImportService,
java.lang.String methodName,
java.lang.Class[] parameterTypes,
ExprEvaluator[] parameters)
|
Uses of EngineImportService in com.espertech.esper.epl.parse |
---|
Methods in com.espertech.esper.epl.parse with parameters of type EngineImportService | |
---|---|
static Pair<ExprTableAccessNode,java.util.List<ExprChainedSpec>> |
ASTTableExprHelper.checkTableNameGetLibFunc(TableService tableService,
EngineImportService engineImportService,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.String engineURI,
java.lang.String classIdent,
java.util.List<ExprChainedSpec> chain)
|
static java.util.List<CreateTableColumn> |
ASTTableHelper.getColumns(java.util.List<EsperEPL2GrammarParser.CreateTableColumnContext> ctxs,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
EngineImportService engineImportService)
|
static Pair<ExprTableAccessNode,java.util.List<ExprChainedSpec>> |
ASTTableExprHelper.getTableExprChainable(EngineImportService engineImportService,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.String engineURI,
java.lang.String tableName,
java.util.List<ExprChainedSpec> chain)
Handle "variable[...].xxxxx......" |
static void |
ASTLibFunctionHelper.handleLibFunc(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.LibFunctionContext ctx,
ConfigurationInformation configurationInformation,
EngineImportService engineImportService,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.String engineURI,
ExpressionDeclDesc expressionDeclarations,
ExprDeclaredService exprDeclaredService,
java.util.List<ExpressionScriptProvided> scriptExpressions,
ContextDescriptor contextDescriptor,
TableService tableService,
StatementSpecRaw statementSpec,
VariableService variableService)
|
static ExprNode |
ASTAggregationHelper.tryResolveAsAggregation(EngineImportService engineImportService,
boolean distinct,
java.lang.String functionName,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.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,
java.util.Map<org.antlr.v4.runtime.tree.Tree,java.lang.Object> astGraphNodeMap,
EngineImportService engineImportService)
|
Constructors in com.espertech.esper.epl.parse with parameters of type EngineImportService | |
---|---|
EPLTreeWalkerListener(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
SelectClauseStreamSelectorEnum defaultStreamSelector,
java.lang.String engineURI,
ConfigurationInformation configurationInformation,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
java.util.List<java.lang.String> scriptBodies,
ExprDeclaredService exprDeclaredService,
TableService tableService)
Ctor. |
Uses of EngineImportService in com.espertech.esper.epl.property |
---|
Methods in com.espertech.esper.epl.property with parameters of type EngineImportService | |
---|---|
static PropertyEvaluator |
PropertyEvaluatorFactory.makeEvaluator(PropertyEvalSpec spec,
EventType sourceEventType,
java.lang.String optionalSourceStreamName,
EventAdapterService eventAdapterService,
EngineImportService engineImportService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
java.lang.String engineURI,
int statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
ConfigurationInformation configuration,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext)
Makes the property evaluator. |
Uses of EngineImportService in com.espertech.esper.epl.spec |
---|
Methods in com.espertech.esper.epl.spec that return EngineImportService | |
---|---|
EngineImportService |
StatementSpecMapContext.getEngineImportService()
Returns the engine import service. |
Methods in com.espertech.esper.epl.spec with parameters of type EngineImportService | |
---|---|
static StatementSpecRaw |
StatementSpecMapper.map(EPStatementObjectModel sodaStatement,
EngineImportService engineImportService,
VariableService variableService,
ConfigurationInformation configuration,
SchedulingService schedulingService,
java.lang.String engineURI,
PatternNodeFactory patternNodeFactory,
NamedWindowMgmtService namedWindowMgmtService,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService)
Maps the SODA object model to a statement specification. |
Constructors in com.espertech.esper.epl.spec with parameters of type EngineImportService | |
---|---|
StatementSpecMapContext(EngineImportService engineImportService,
VariableService variableService,
ConfigurationInformation configuration,
SchedulingService schedulingService,
java.lang.String engineURI,
PatternNodeFactory patternNodeFactory,
NamedWindowMgmtService namedWindowMgmtService,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
ContextDescriptor contextDescriptor,
TableService tableService)
Ctor. |
Uses of EngineImportService in com.espertech.esper.epl.table.mgmt |
---|
Methods in com.espertech.esper.epl.table.mgmt with parameters of type EngineImportService | |
---|---|
Pair<ExprNode,java.util.List<ExprChainedSpec>> |
TableServiceImpl.getTableNodeChainable(StreamTypeService streamTypeService,
java.util.List<ExprChainedSpec> chainSpec,
EngineImportService engineImportService)
|
Pair<ExprNode,java.util.List<ExprChainedSpec>> |
TableService.getTableNodeChainable(StreamTypeService streamTypeService,
java.util.List<ExprChainedSpec> chainSpec,
EngineImportService engineImportService)
|
Constructors in com.espertech.esper.epl.table.mgmt with parameters of type EngineImportService | |
---|---|
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 | |
---|---|
void |
VariableServiceImpl.createNewVariable(java.lang.String optionalContextName,
java.lang.String variableName,
java.lang.String variableType,
boolean constant,
boolean array,
boolean arrayOfPrimitive,
java.lang.Object value,
EngineImportService engineImportService)
|
void |
VariableService.createNewVariable(java.lang.String optionalContextName,
java.lang.String variableName,
java.lang.String type,
boolean constant,
boolean array,
boolean arrayOfPrimitive,
java.lang.Object value,
EngineImportService engineImportService)
Creates a new variable. |
Uses of EngineImportService in com.espertech.esper.event |
---|
Methods in com.espertech.esper.event with parameters of type EngineImportService | |
---|---|
static java.lang.Object |
EventTypeUtility.buildType(ColumnDesc column,
EngineImportService engineImportService)
|
static java.util.LinkedHashMap<java.lang.String,java.lang.Object> |
EventTypeUtility.buildType(java.util.List<ColumnDesc> columns,
EventAdapterService eventAdapterService,
java.util.Set<java.lang.String> copyFrom,
EngineImportService engineImportService)
|
static EventType |
EventTypeUtility.createNonVariantType(boolean isAnonymous,
CreateSchemaDesc spec,
java.lang.annotation.Annotation[] annotations,
ConfigurationInformation configSnapshot,
EventAdapterService eventAdapterService,
EngineImportService engineImportService)
|
static EventBeanManufacturer |
EventAdapterServiceHelper.getManufacturer(EventAdapterService eventAdapterService,
EventType eventType,
WriteablePropertyDescriptor[] properties,
EngineImportService engineImportService,
boolean allowAnyType)
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. |
Uses of EngineImportService in com.espertech.esper.event.bean |
---|
Methods in com.espertech.esper.event.bean with parameters of type EngineImportService | |
---|---|
static Pair<net.sf.cglib.reflect.FastConstructor,ExprEvaluator[]> |
InstanceManufacturerUtil.getManufacturer(java.lang.Class targetClass,
EngineImportService engineImportService,
ExprEvaluator[] exprEvaluators,
java.lang.Object[] expressionReturnTypes)
|
static InstanceManufacturer |
InstanceManufacturerFactory.getManufacturer(java.lang.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 | |
---|---|
EventBeanManufacturerBean(BeanEventType beanEventType,
EventAdapterService service,
WriteablePropertyDescriptor[] properties,
EngineImportService engineImportService)
Ctor. |
Uses of EngineImportService in com.espertech.esper.filter |
---|
Fields in com.espertech.esper.filter declared as EngineImportService | |
---|---|
EngineImportService |
FilterSpecCompilerArgs.engineImportService
|
Methods in com.espertech.esper.filter with parameters of type EngineImportService | |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedFilterNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext)
|
Constructors in com.espertech.esper.filter with parameters of type EngineImportService | |
---|---|
FilterSpecCompilerArgs(java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String statementName,
int statementId,
StreamTypeService streamTypeService,
EngineImportService engineImportService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configurationInformation,
StatementExtensionSvcContext statementExtensionSvcContext)
|
Uses of EngineImportService in com.espertech.esper.util |
---|
Methods in com.espertech.esper.util with parameters of type EngineImportService | |
---|---|
static java.lang.Object |
PopulateUtil.coerceProperty(java.lang.String propertyName,
java.lang.Class containingType,
java.lang.Object value,
java.lang.Class type,
EngineImportService engineImportService,
boolean forceNumeric,
boolean includeClassNameInEx)
|
static java.lang.Object |
JavaClassHelper.getAnnotationHook(java.lang.annotation.Annotation[] annotations,
HookType hookType,
java.lang.Class interfaceExpected,
EngineImportService optionalResolver)
Returns an instance of a hook as specified by an annotation. |
static java.lang.Object |
PopulateUtil.instantiatePopulateObject(java.util.Map<java.lang.String,java.lang.Object> objectProperties,
java.lang.Class topClass,
EngineImportService engineImportService)
|
static java.lang.Object |
JsonUtil.parsePopulate(java.lang.String json,
java.lang.Class topClass,
EngineImportService engineImportService)
|
static void |
PopulateUtil.populateObject(java.lang.String operatorName,
int operatorNum,
java.lang.String dataFlowName,
java.util.Map<java.lang.String,java.lang.Object> objectProperties,
java.lang.Object top,
EngineImportService engineImportService,
EPDataFlowOperatorParameterProvider optionalParameterProvider,
java.util.Map<java.lang.String,java.lang.Object> optionalParameterURIs)
|
static void |
PopulateUtil.populateSpecCheckParameters(PopulateFieldWValueDescriptor[] descriptors,
java.util.Map<java.lang.String,java.lang.Object> jsonRaw,
java.lang.Object spec,
EngineImportService engineImportService)
|
static java.lang.Object |
JavaClassHelper.resolveIdentAsEnumConst(java.lang.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 | |
---|---|
void |
ValidatedView.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
Validate the view. |
|
© 2006-2016 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |