Package | Description |
---|---|
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.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.join.util |
Join-related utilities
|
com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
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.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.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.
|
Constructor and Description |
---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static Module |
EPLModuleUtil.readResource(String resource,
EngineImportService 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.
|
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.
|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
static Annotation[] |
AnnotationUtil.compileAnnotations(List<AnnotationDesc> annotationSpec,
EngineImportService engineImportService,
String eplStatement)
Compile annotation objects from descriptors.
|
Modifier and Type | Class and Description |
---|---|
class |
EngineImportServiceImpl
Implementation for engine-level imports.
|
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,
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) |
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) |
Constructor and Description |
---|
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) |
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) |
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) |
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.
|
Modifier and Type | Method and Description |
---|---|
abstract EnumEval |
ExprDotEvalEnumMethodBase.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
Modifier and Type | Method and Description |
---|---|
EnumEval |
ExprDotEvalWhere.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalToMap.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalTakeWhileAndLast.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalTakeAndTakeLast.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalSumOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalSetExceptUnionIntersect.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalSequenceEqual.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalSelectFrom.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalReverse.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalOrderByAscDesc.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalNoOp.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalMostLeastFrequent.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalMinMax.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalMinByMaxBy.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalGroupBy.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalFirstLastOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalDistinct.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalCountOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalAverage.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalAllOfAnyOf.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
EnumEval |
ExprDotEvalAggregate.getEnumEval(EngineImportService engineImportService,
EventAdapterService eventAdapterService,
StreamTypeService streamTypeService,
int statementId,
String enumMethodUsedName,
List<ExprDotEvalParam> bodiesAndParameters,
EventType inputEventType,
Class collectionComponentType,
int numStreamsIncoming,
boolean disablePropertyExpressionEventCollCache) |
Constructor and Description |
---|
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
Modifier and Type | Method and Description |
---|---|
EngineImportService |
ExprValidationContext.getEngineImportService() |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Constructor and Description |
---|
ExprDotMethodEvalDuck(String statementName,
EngineImportService engineImportService,
String methodName,
Class[] parameterTypes,
ExprEvaluator[] parameters) |
Modifier and Type | Method and Description |
---|---|
static QueryPlanIndexHook |
QueryPlanIndexHookUtil.getHook(Annotation[] annotations,
EngineImportService engineImportService) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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) |
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).
|
Modifier and Type | Method and Description |
---|---|
EngineImportService |
StatementSpecMapContext.getEngineImportService()
Returns the engine import service.
|
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) |
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) |
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) |
Constructor and Description |
---|
TableStateRowFactory(ObjectArrayEventType objectArrayEventType,
EngineImportService engineImportService,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
int[] groupKeyIndexes,
EventAdapterService eventAdapterService) |
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) |
Modifier and Type | Method and Description |
---|---|
EngineImportService |
EventAdapterServiceImpl.getEngineImportService() |
EngineImportService |
EventAdapterService.getEngineImportService() |
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.
|
Constructor and Description |
---|
EventAdapterServiceImpl(EventTypeIdGenerator eventTypeIdGenerator,
int anonymousTypeCacheSize,
EventAdapterAvroHandler avroHandler,
EngineImportService 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) |
Modifier and Type | Method and Description |
---|---|
static Pair<net.sf.cglib.reflect.FastConstructor,ExprEvaluator[]> |
InstanceManufacturerUtil.getManufacturer(Class targetClass,
EngineImportService engineImportService,
ExprEvaluator[] exprEvaluators,
Object[] expressionReturnTypes) |
static InstanceManufacturer |
InstanceManufacturerFactory.getManufacturer(Class targetClass,
EngineImportService engineImportService,
ExprNode[] childNodes) |
static BeanInstantiator |
BeanInstantiatorFactory.makeInstantiator(BeanEventType beanEventType,
EngineImportService engineImportService) |
Constructor and Description |
---|
EventBeanManufacturerBean(BeanEventType beanEventType,
EventAdapterService service,
WriteablePropertyDescriptor[] properties,
EngineImportService engineImportService)
Ctor.
|
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.
|
Modifier and Type | Field and Description |
---|---|
EngineImportService |
FilterSpecCompilerArgs.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) |
Constructor and Description |
---|
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) |
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.
|
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.
|