Package | Description |
---|---|
com.espertech.esper.client.hook |
Callback interfaces for use with statement annotations.
|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
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.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.datetime.calop |
Date-Time calendar operations.
|
com.espertech.esper.epl.datetime.eval |
Date-Time methods and related utility classes.
|
com.espertech.esper.epl.datetime.interval |
Interval algebra.
|
com.espertech.esper.epl.datetime.reformatop |
Date-Time re-formatting operations.
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
com.espertech.esper.epl.declexpr |
Declared expression handling.
|
com.espertech.esper.epl.enummethod.dot |
Enumeration method utility classes and input data sources.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.expression.baseagg |
Base 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.funcs |
Function expressions.
|
com.espertech.esper.epl.expression.methodagg |
Method-aggregation expressions.
|
com.espertech.esper.epl.expression.ops |
Operator expressions.
|
com.espertech.esper.epl.expression.prev |
'Previous'-group expressions.
|
com.espertech.esper.epl.expression.prior |
'Prior'-group expressions.
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.expression.table |
Table access and identifiers expressions.
|
com.espertech.esper.epl.expression.time |
Time-related expressions.
|
com.espertech.esper.epl.expression.visitor |
Expression visitors.
|
com.espertech.esper.epl.index.quadtree |
Quad-tree indexes
|
com.espertech.esper.epl.index.service |
Advanced index provisioning
|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.join.exec.base |
Inner join execution
|
com.espertech.esper.epl.join.hint |
Hints related to joins.
|
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.methodbase |
Dot-method validation for enumeration and date-time methods.
|
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.rettype |
EPL-internal expression return type.
|
com.espertech.esper.epl.script |
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.spec.util |
Statement spec utilities
|
com.espertech.esper.epl.subquery |
Subquery helper classes are found here.
|
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.table.strategy |
Table access evaluators.
|
com.espertech.esper.epl.util |
EPL utility classes.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
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.metrics.instrumentation |
EPL instrumentation helpers.
|
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.pattern.guard |
Pattern guards that can define the lifetime of a pattern
|
com.espertech.esper.pattern.observer |
Pattern observer classes the observe timer events
|
com.espertech.esper.plugin |
APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in
this package.
|
com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
com.espertech.esper.type |
Internal primitive, enum and other type representations
|
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.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.stat |
Views computing statistical values.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.window |
Window views are in this package
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
VirtualDataWindowEventConsumerAdd.getFilterExpressions()
Provides the filter expressions.
|
ExprNode[] |
VirtualDataWindowFactoryContext.getParameterExpressions()
Returns the expressions passed as parameters to the virtual data window.
|
ExprNode[] |
VirtualDataWindowContext.getParameterExpressions()
Returns the expressions passed as parameters to the virtual data window.
|
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
VirtualDataWindowEventStartIndex.VDWCreateIndexField.getExpressions()
Returns index expressions
|
List<ExprNode> |
VirtualDataWindowEventStartIndex.VDWCreateIndexField.getParameters()
Returns index field parameters if any
|
Constructor and Description |
---|
VirtualDataWindowContext(AgentInstanceContext agentInstanceContext,
EventType eventType,
Object[] parameters,
ExprNode[] parameterExpressions,
EventBeanFactory eventFactory,
VirtualDataWindowOutStream outputStream,
String namedWindowName,
ViewFactoryContext viewFactoryContext,
Serializable customConfiguration)
Ctor.
|
VirtualDataWindowEventConsumerAdd(String namedWindowName,
Object consumerObject,
String statementName,
int agentInstanceId,
ExprNode[] filterExpressions,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
VirtualDataWindowFactoryContext(EventType eventType,
Object[] parameters,
ExprNode[] parameterExpressions,
EventBeanFactory eventFactory,
String namedWindowName,
ViewFactoryContext viewFactoryContext,
Serializable customConfiguration)
Ctor.
|
Constructor and Description |
---|
VDWCreateIndexField(List<ExprNode> expressions,
String type,
List<ExprNode> parameters)
Ctor.
|
VDWCreateIndexField(List<ExprNode> expressions,
String type,
List<ExprNode> parameters)
Ctor.
|
Constructor and Description |
---|
ViewableActivatorNamedWindow(NamedWindowProcessor processor,
List<ExprNode> filterExpressions,
PropertyEvaluator optPropertyEvaluator,
EngineImportService engineImportService,
String statementName) |
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) |
Constructor and Description |
---|
SubSelectStrategyFactoryLocalViewPreloaded(int subqueryNumber,
SubSelectActivationHolder subSelectHolder,
Pair<EventTableFactory,SubordTableLookupStrategyFactory> pair,
ExprNode filterExprNode,
ExprEvaluator filterExprEval,
boolean correlatedSubquery,
AggregationServiceFactoryDesc aggregationServiceFactory,
ViewResourceDelegateVerified viewResourceDelegate,
ExprEvaluator[] groupKeys) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
EPAdministratorSPI.compileExpression(String expression)
Compile expression.
|
ExprNode |
EPAdministratorImpl.compileExpression(String expression) |
Constructor and Description |
---|
InternalEventRouterEntry(int priority,
boolean drop,
ExprEvaluator optionalWhereClause,
ExprNode[] assignments,
EventBeanWriter writer,
TypeWidener[] wideners,
InternalRoutePreprocessView outputView,
StatementAgentInstanceLock agentInstanceLock,
boolean hasSubselect)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
EPPreparedExecuteIUDSingleStreamExecUpdate.getOptionalWhereClause() |
ExprNode |
EPPreparedExecuteIUDSingleStreamExecDelete.getOptionalWhereClause() |
ExprNode |
EPStatementStartMethodOnTriggerItem.getWhereClause() |
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
String errorMsg,
boolean allowTableConsumption) |
protected ExprNode |
EPStatementStartMethodOnTrigger.validateJoinNamedWindow(String engineURI,
StatementContext statementContext,
ExprNodeOrigin exprNodeOrigin,
ExprNode deleteJoinExpr,
EventType namedWindowType,
String namedWindowStreamName,
String namedWindowName,
EventType filteredType,
String filterStreamName,
String filteredTypeName,
String optionalTableName) |
Modifier and Type | Method and Description |
---|---|
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
String errorMsg,
boolean allowTableConsumption) |
protected ExprNode |
EPStatementStartMethodOnTrigger.validateJoinNamedWindow(String engineURI,
StatementContext statementContext,
ExprNodeOrigin exprNodeOrigin,
ExprNode deleteJoinExpr,
EventType namedWindowType,
String namedWindowStreamName,
String namedWindowName,
EventType filteredType,
String filterStreamName,
String filteredTypeName,
String optionalTableName) |
protected static void |
EPStatementStartMethodHelperValidate.validateNoAggregations(ExprNode exprNode,
String errorMsg) |
protected static void |
EPStatementStartMethodHelperValidate.validateSubqueryExcludeOuterStream(ExprNode matchCondition) |
Constructor and Description |
---|
EPPreparedExecuteIUDSingleStreamExecDelete(QueryGraph queryGraph,
ExprNode optionalWhereClause,
Annotation[] annotations,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPPreparedExecuteIUDSingleStreamExecUpdate(QueryGraph queryGraph,
ExprNode optionalWhereClause,
Annotation[] annotations,
EventBeanUpdateHelper updateHelper,
TableUpdateStrategy tableUpdateStrategy,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPStatementStartMethodOnTriggerItem(ExprNode whereClause,
boolean isNamedWindowInsert,
String insertIntoTableNames,
ResultSetProcessorFactoryDesc factoryDesc,
PropertyEvaluator propertyEvaluator) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
EventBusSource.filter |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
AggregationMethodFactoryAvedev.positionalParameters |
Modifier and Type | Method and Description |
---|---|
ExprNode |
AggregationStateFactorySorted.getAggregationExpression() |
ExprNode |
AggregationStateFactoryPlugin.getAggregationExpression() |
ExprNode |
AggregationStateFactoryMinMaxByEver.getAggregationExpression() |
ExprNode |
AggregationStateFactoryLinear.getAggregationExpression() |
ExprNode |
AggregationStateFactoryCountMinSketch.getAggregationExpression() |
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
AggregationMethodFactoryCount.getMethodAggregationEvaluatorCountBy(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
Class childType,
ExprNode[] positionalParams) |
Constructor and Description |
---|
AggregationMethodFactoryAvedev(ExprAvedevNode parent,
Class aggregatedValueType,
ExprNode[] positionalParameters) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
GroupByRollupPlanDesc.getExpressions() |
Modifier and Type | Method and Description |
---|---|
static GroupByClauseExpressions |
GroupByExpressionHelper.getGroupByRollupExpressions(List<GroupByClauseElement> groupByElements,
SelectClauseSpecRaw selectClauseSpec,
ExprNode optionalHavingNode,
List<OrderByItem> orderByList,
ExprNodeSubselectDeclaredDotVisitor visitor) |
int |
GroupByRollupEvalContext.getIndex(ExprNode node) |
Constructor and Description |
---|
GroupByRollupNodeSingleExpr(ExprNode expression) |
GroupByRollupPlanDesc(ExprNode[] expressions,
AggregationGroupByRollupDesc rollupDesc) |
Constructor and Description |
---|
GroupByRollupEvalContext(Map<ExprNode,Integer> expressionToIndex) |
GroupByRollupNodeCombinedExpr(List<ExprNode> expressions) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
AggSvcGroupByWTableBase.accessStateExpr |
Modifier and Type | Method and Description |
---|---|
ExprNode |
AggregationStateFactory.getAggregationExpression() |
ExprNode[] |
AggregationValidationContext.getExpressions()
Returns the parameter expressions themselves for interrogation.
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,List<ExprNode>> |
AggregationValidationContext.getNamedParameters()
Returns any named parameters or null if there are no named parameters
|
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
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 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) |
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,
String statementName) |
Constructor and Description |
---|
AggregationStateKeyWStream(int streamNum,
EventType eventType,
AggregationStateTypeWStream stateType,
ExprNode[] criteraExprNodes,
ExprNode filterExprNode) |
AggregationStateKeyWStream(int streamNum,
EventType eventType,
AggregationStateTypeWStream stateType,
ExprNode[] criteraExprNodes,
ExprNode filterExprNode) |
AggregationValidationContext(Class[] parameterTypes,
boolean[] constantValue,
Object[] constantValues,
boolean distinct,
boolean windowed,
ExprNode[] expressions,
LinkedHashMap<String,List<ExprNode>> namedParameters)
Ctor.
|
AggSvcGroupAllMixedAccessWTableFactory(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggSvcGroupAllMixedAccessWTableImpl(TableStateInstanceUngrouped tableStateInstance,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggSvcGroupByWTableBase(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
TableStateInstanceGrouped tableStateInstance,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggSvcGroupByWTableFactory(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggSvcGroupByWTableImpl(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
TableStateInstanceGrouped tableStateInstance,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggSvcGroupByWTableRollupMultiKeyImpl(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
TableStateInstanceGrouped tableStateInstance,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggSvcGroupByWTableRollupSingleKeyImpl(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
TableStateInstanceGrouped tableStateInstance,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
Constructor and Description |
---|
AggregationValidationContext(Class[] parameterTypes,
boolean[] constantValue,
Object[] constantValues,
boolean distinct,
boolean windowed,
ExprNode[] expressions,
LinkedHashMap<String,List<ExprNode>> namedParameters)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
AggregationGroupByLocalGroupLevel.getPartitionExpr() |
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) |
Constructor and Description |
---|
AggregationGroupByLocalGroupLevel(ExprNode[] partitionExpr,
List<AggregationServiceAggExpressionDesc> expressions) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
OrderByElement.getExprNode() |
ExprNode[] |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNodeExpressions() |
ExprNode[] |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNodeExpressions() |
ExprNode[] |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNodeExpressions() |
ExprNode[] |
EngineImportApplicationDotMethod.getLhs() |
ExprNode[] |
EngineImportApplicationDotMethod.getRhs() |
ExprNode |
EngineImportServiceImpl.resolveAggExtendedBuiltin(String name,
boolean isDistinct) |
ExprNode |
EngineImportService.resolveAggExtendedBuiltin(String name,
boolean isDistinct)
Resolve an extended (non-SQL std) builtin aggregation.
|
ExprNode |
EngineImportServiceImpl.resolveSingleRowExtendedBuiltin(String name) |
ExprNode |
EngineImportService.resolveSingleRowExtendedBuiltin(String name)
Resolve an extended (non-SQL std) single-row function.
|
static ExprNode |
ColumnNamedNodeSwapper.swap(ExprNode exprTree,
String columnName,
ExprNode fullExpr)
Replace all instances of the node representing the colum name with
the full expression.
|
ExprNode |
EngineImportApplicationDotMethod.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionExpression(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionExpression(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
SelectExprProcessor |
SelectExprProcessorRepresentationFactory.makeRecast(EventType[] eventTypes,
SelectExprContext selectExprContext,
int streamNumber,
AvroSchemaEventType insertIntoTargetType,
ExprNode[] exprNodes,
String statementName,
String engineURI) |
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprNode[] groupKeyExpressions,
int numStreams) |
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactory.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprNode[] groupKeyExpressions,
int numStreams) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
ExprNode[] groupKeyNodeExpressions,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
ExprNode[] groupKeyNodeExpressions,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
static ExprNode |
ColumnNamedNodeSwapper.swap(ExprNode exprTree,
String columnName,
ExprNode fullExpr)
Replace all instances of the node representing the colum name with
the full expression.
|
Modifier and Type | Method and Description |
---|---|
OutputConditionFactory |
ResultSetProcessorHelperFactoryImpl.makeOutputConditionCrontab(List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionCrontab(List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
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 |
---|
OrderByElement(ExprNode exprNode,
ExprEvaluator expr,
boolean descending) |
ResultSetProcessorAggregateGroupedFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
boolean enableOutputLimitOpt,
int numStreams) |
ResultSetProcessorRowPerGroupFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean enableOutputLimitOpt,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
ResultSetProcessorRowPerGroupRollupFactory(GroupByRollupPerLevelExpression perLevelExpression,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean enableOutputLimitOpt,
int numStreams) |
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 |
---|---|
static CalendarFieldEnum |
CalendarOpUtil.getEnum(String methodName,
ExprNode exprNode) |
static Object |
CalendarOpUtil.getFormatter(EPType inputType,
String methodName,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
CalendarForge |
CalendarForgeFactory.getOp(DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
ExprForge[] forges) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
FilterExprAnalyzerDTIntervalAffector.getIndexExpressions() |
ExprNode[] |
FilterExprAnalyzerDTBetweenAffector.getIndexExpressions() |
Modifier and Type | Method and Description |
---|---|
List<Pair<ExprNode,int[]>> |
FilterExprAnalyzerDTIntervalAffector.getKeyExpressions() |
List<Pair<ExprNode,int[]>> |
FilterExprAnalyzerDTBetweenAffector.getKeyExpressions() |
Modifier and Type | Method and Description |
---|---|
static ExprDotDTMethodDesc |
ExprDotDTFactory.validateMake(StreamTypeService streamTypeService,
Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
String dtMethodName,
EPType inputType,
List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
TimeZone timeZone,
TimeAbacus timeAbacus,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
FilterExprAnalyzerDTBetweenAffector(EventType[] typesPerStream,
int targetStreamNum,
String targetPropertyName,
ExprNode start,
ExprNode end,
boolean includeLow,
boolean includeHigh) |
Modifier and Type | Method and Description |
---|---|
FilterExprAnalyzerDTIntervalAffector |
IntervalForgeImpl.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc)
Obtain information used by filter analyzer to handle this dot-method invocation as part of query planning/indexing.
|
FilterExprAnalyzerDTIntervalAffector |
IntervalForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
IntervalForge |
IntervalForgeFactory.getForge(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputerForge |
IntervalComputerForgeFactory.make(DatetimeMethodEnum method,
List<ExprNode> expressions,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalForgeImpl(DatetimeMethodEnum method,
String methodNameUse,
StreamTypeService streamTypeService,
List<ExprNode> expressions,
TimeZone timeZone,
TimeAbacus timeAbacus) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ReformatBetweenNonConstantParamsForge.end |
protected ExprNode |
ReformatBetweenNonConstantParamsForge.start |
Constructor and Description |
---|
ReformatBetweenConstantParamsForge(List<ExprNode> parameters,
TimeZone timeZone) |
ReformatBetweenNonConstantParamsForge(List<ExprNode> parameters,
TimeZone timeZone) |
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) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprDeclaredNode
Expression instance as declared elsewhere.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprDeclaredNodeImpl
Expression instance as declared elsewhere.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDeclaredNodeImpl.getBody() |
ExprNode |
ExprDeclaredNode.getBody() |
ExprNode |
ExprDeclaredNodeImpl.getExpressionBodyCopy() |
ExprNode |
ExprDeclaredForgeBase.getForgeRenderable() |
ExprNode |
ExprDeclaredNodeImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ExprDeclaredNodeImpl.getAdditionalNodes() |
List<ExprNode> |
ExprDeclaredNodeImpl.getChainParameters() |
List<ExprNode> |
ExprDeclaredNode.getChainParameters() |
Modifier and Type | Method and Description |
---|---|
void |
ExprDeclaredNodeImpl.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
boolean |
ExprDeclaredNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Method and Description |
---|---|
static ExprDeclaredNodeImpl |
ExprDeclaredHelper.getExistsDeclaredExpr(String name,
List<ExprNode> parameters,
Collection<ExpressionDeclItem> expressionDeclarations,
ExprDeclaredService exprDeclaredService,
ContextDescriptor contextDescriptor) |
static ExprNodeScript |
ExprDeclaredHelper.getExistsScript(String defaultDialect,
String expressionName,
List<ExprNode> parameters,
Collection<ExpressionScriptProvided> scriptExpressions,
ExprDeclaredService exprDeclaredService) |
Constructor and Description |
---|
ExprDeclaredNodeImpl(ExpressionDeclItem prototype,
List<ExprNode> chainParameters,
ContextDescriptor contextDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
ExprLambdaGoesNode
Represents the case-when-then-else control flow function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDotEvalParam.getBody() |
ExprNode |
ExprLambdaGoesNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprLambdaGoesNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Method and Description |
---|---|
void |
ExprDotForgeEnumMethodBase.init(Integer streamOfProviderIfApplicable,
EnumMethodEnum enumMethodEnum,
String enumMethodUsedName,
EPType typeInfo,
List<ExprNode> parameters,
ExprValidationContext validationContext) |
void |
ExprDotForgeEnumMethod.init(Integer streamOfProviderIfApplicable,
EnumMethodEnum lambda,
String lambdaUsedName,
EPType currentInputType,
List<ExprNode> parameters,
ExprValidationContext validationContext) |
Constructor and Description |
---|
ExprDotEvalParam(int parameterNum,
ExprNode body,
ExprForge bodyForge) |
ExprDotEvalParamExpr(int parameterNum,
ExprNode body,
ExprForge bodyForge) |
ExprDotEvalParamLambda(int parameterNum,
ExprNode body,
ExprForge bodyEvaluator,
int streamCountIncoming,
List<String> goesToNames,
EventType[] goesToTypes) |
Modifier and Type | Class and Description |
---|---|
class |
ExprAggCountMinSketchNode
Represents the Count-min sketch aggregate function.
|
class |
ExprAggMultiFunctionLinearAccessNode |
class |
ExprAggMultiFunctionSortedMinMaxByNode |
class |
ExprPlugInAggMultiFunctionNode
Represents a custom aggregation function in an expresson tree.
|
Modifier and Type | Method and Description |
---|---|
static AggregationAgent |
ExprAggAggregationAgentFactory.make(int streamNum,
ExprNode optionalFilter,
EngineImportService engineImportService,
boolean isFireAndForget,
String statementName) |
static int |
ExprAggMultiFunctionUtil.validateStreamWildcardGetStreamNum(ExprNode node) |
Constructor and Description |
---|
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprNode[] expressions,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAggregateNode
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAggregateNodeBase
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
class |
ExprAggregateNodeGroupKey |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExprAggregateNodeBase.optionalFilter |
protected ExprNode[] |
ExprAggregateNodeBase.positionalParams |
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprAggregateNodeGroupKey.getForgeRenderable() |
ExprNode |
ExprAggregateNodeBase.getForgeRenderable() |
ExprNode |
ExprAggregateNodeParamDesc.getOptionalFilter() |
ExprNode |
ExprAggregateNodeBase.getOptionalFilter() |
ExprNode[] |
ExprAggregateLocalGroupByDesc.getPartitionExpressions() |
ExprNode[] |
ExprAggregateNodeParamDesc.getPositionalParams() |
ExprNode[] |
ExprAggregateNodeBase.getPositionalParams() |
ExprNode[] |
ExprAggregateNode.getPositionalParams() |
ExprNode |
ExprAggregateNodeGroupKey.validate(ExprValidationContext validationContext) |
ExprNode |
ExprAggregateNodeBase.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprAggregateNodeGroupKey.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprAggregateNodeBase.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode[][] nodes,
List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode[] nodes,
List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode topNode,
List<ExprAggregateNode> aggregateNodes)
Populates into the supplied list all aggregation functions within this expression, if any.
|
static ExprAggregateNodeParamDesc |
ExprAggregateNodeUtil.getValidatePositionalParams(ExprNode[] childNodes,
boolean builtinAggregationFunc) |
static boolean |
ExprAggregateNodeUtil.isNonPositionalParameter(ExprNode node) |
Modifier and Type | Method and Description |
---|---|
static int |
ExprAggregateNodeUtil.countPositionalArgs(List<ExprNode> args) |
Constructor and Description |
---|
ExprAggregateLocalGroupByDesc(ExprNode[] partitionExpressions) |
ExprAggregateNodeParamDesc(ExprNode[] positionalParams,
ExprAggregateLocalGroupByDesc optLocalGroupBy,
ExprNode optionalFilter) |
ExprAggregateNodeParamDesc(ExprNode[] positionalParams,
ExprAggregateLocalGroupByDesc optLocalGroupBy,
ExprNode optionalFilter) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprConstantNode
Represents a constant in an expressiun tree.
|
interface |
ExprIdentNode
Represents an stream property identifier in a filter expressiun tree.
|
interface |
ExprStreamRefNode
Represents a stream-reference.
|
interface |
ExprStreamUnderlyingNode
Represents an stream selector that returns the streams underlying event, or null if undefined.
|
interface |
ExprVariableNode
Represents a variable in an expression tree.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprConstantNodeImpl
Represents a constant in an expressiun tree.
|
class |
ExprContextPropertyNodeImpl
Represents an stream property identifier in a filter expressiun tree.
|
class |
ExprCurrentEvaluationContextNode
Represents the "current_evaluation_context" function in an expression tree.
|
class |
ExprGroupingIdNode |
class |
ExprGroupingNode |
class |
ExprIdentNodeImpl
Represents an stream property identifier in a filter expressiun tree.
|
class |
ExprNamedParameterNodeImpl |
class |
ExprNodeBase
Superclass for filter nodes in a filter expression tree.
|
class |
ExprNodeValidated
A placeholder for another expression node that has been validated already.
|
class |
ExprNumberSetCronParam
Expression for a parameter within a crontab.
|
class |
ExprNumberSetFrequency
Expression for use within crontab to specify a frequency.
|
class |
ExprNumberSetList
Expression for use within crontab to specify a list of values.
|
class |
ExprNumberSetRange
Expression for use within crontab to specify a range.
|
class |
ExprOrderedExpr
A placeholder expression for view/pattern object parameters that allow
sorting expression values ascending or descending.
|
class |
ExprStreamUnderlyingNodeImpl
Represents an stream selector that returns the streams underlying event, or null if undefined.
|
class |
ExprSubstitutionNode
Represents a substitution value to be substituted in an expression tree, not valid for any purpose of use
as an expression, however can take a place in an expression tree.
|
class |
ExprTypedNoEvalNode
Represents an expression node that returns the predefined type and
that cannot be evaluated.
|
class |
ExprVariableNodeImpl
Represents a variable in an expression tree.
|
class |
ExprWildcardImpl
Expression for use within crontab to specify a wildcard.
|
Modifier and Type | Field and Description |
---|---|
static ExprNode[] |
ExprNodeUtility.EMPTY_EXPR_ARRAY |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ExprNodeUtility.addExpression(ExprNode[] expressions,
ExprNode expression) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAndWhenNeeded(Collection<ExprNode> nodes) |
ExprNode[] |
ExprNodeBase.getChildNodes() |
ExprNode[] |
ExprNode.getChildNodes()
Returns list of child nodes.
|
ExprNode[] |
ExprNamedParameterNode.getChildNodes() |
ExprNode |
ExprStreamUnderlyingNodeImpl.getForgeRenderable() |
ExprNode |
ExprNamedParameterNodeImpl.getForgeRenderable() |
ExprNode |
ExprNodeProxy.getOriginalObject() |
ExprNode |
ExprNodePropOrStreamExprDesc.getOriginator() |
static ExprNode |
ExprNodeUtility.getValidatedAssignment(OnTriggerSetAssignment assignment,
ExprValidationContext validationContext) |
static ExprNode |
ExprNodeUtility.getValidatedSubtree(ExprNodeOrigin origin,
ExprNode exprNode,
ExprValidationContext validationContext)
Validates the expression node subtree that has this
node as root.
|
static ExprNode[] |
ExprNodeUtility.toArray(Collection<ExprNode> expressions) |
ExprNode |
ExprWildcardImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprVariableNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprValidator.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTypedNoEvalNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprSubstitutionNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprStreamUnderlyingNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprOrderedExpr.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetRange.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetList.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetFrequency.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetCronParam.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNodeValidated.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNamedParameterNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprIdentNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprGroupingNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprGroupingIdNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCurrentEvaluationContextNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprContextPropertyNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprConstantNodeImpl.validate(ExprValidationContext validationContext) |
static ExprNode |
ExprNodeUtility.validateSimpleGetSubtree(ExprNodeOrigin origin,
ExprNode expression,
StatementContext statementContext,
EventType optionalEventType,
boolean allowBindingConsumption) |
Modifier and Type | Method and Description |
---|---|
static Pair<String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToProp(ExprNode node) |
static Pair<String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToVariableOrProp(ExprNode node) |
static List<ExprNode> |
ExprNodeUtility.collectChainParameters(List<ExprChainedSpec> chainSpec) |
static List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
static List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
List<ExprNode> |
ExprNodeInnerNodeProvider.getAdditionalNodes() |
List<ExprNode> |
ExprChainedSpec.getParameters() |
Modifier and Type | Method and Description |
---|---|
static void |
ExprNodeUtility.acceptChain(ExprNodeVisitorWithParent visitor,
List<ExprChainedSpec> chainSpec,
ExprNode parent) |
void |
ExprNodeBase.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
void |
ExprNode.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent)
Accept a visitor that receives both parent and child node.
|
void |
ExprNodeBase.addChildNode(ExprNode childNode) |
void |
ExprNode.addChildNode(ExprNode childNode)
Adds a child node.
|
void |
ExprNodeBase.addChildNodeToFront(ExprNode childNode) |
static ExprNode[] |
ExprNodeUtility.addExpression(ExprNode[] expressions,
ExprNode expression) |
static ExprNode[] |
ExprNodeUtility.addExpression(ExprNode[] expressions,
ExprNode expression) |
static void |
ExprNodeUtility.addNonAggregatedProps(ExprNode exprNode,
ExprNodePropOrStreamSet set,
EventType[] types,
ContextPropertyRegistry contextPropertyRegistry) |
static Pair<String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToProp(ExprNode node) |
static Pair<String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToVariableOrProp(ExprNode node) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static boolean |
ExprNodeUtility.deepEquals(ExprNode[] one,
ExprNode[] two,
boolean ignoreStreamPrefix)
Compares two expression nodes via deep comparison, considering all
child nodes of either side.
|
static boolean |
ExprNodeUtility.deepEquals(ExprNode[] one,
ExprNode[] two,
boolean ignoreStreamPrefix)
Compares two expression nodes via deep comparison, considering all
child nodes of either side.
|
static boolean |
ExprNodeUtility.deepEquals(ExprNode nodeOne,
ExprNode nodeTwo,
boolean ignoreStreamPrefix)
Compare two expression nodes and their children in exact child-node sequence,
returning true if the 2 expression nodes trees are equals, or false if they are not equals.
|
static boolean |
ExprNodeUtility.deepEqualsIgnoreDupAndOrder(ExprNode[] setOne,
ExprNode[] setTwo) |
static boolean |
ExprNodeUtility.deepEqualsIgnoreDupAndOrder(ExprNode[] setOne,
ExprNode[] setTwo) |
static boolean |
ExprNodeUtility.deepEqualsIsSubset(ExprNode[] subset,
ExprNode[] superset) |
static boolean |
ExprNodeUtility.deepEqualsIsSubset(ExprNode[] subset,
ExprNode[] superset) |
boolean |
ExprWildcardImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprVariableNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTypedNoEvalNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprSubstitutionNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprStreamUnderlyingNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprOrderedExpr.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetRange.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetList.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetFrequency.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetCronParam.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNodeValidated.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix)
Return true if a expression node semantically equals the current node, or false if not.
|
boolean |
ExprNamedParameterNodeImpl.equalsNode(ExprNode other,
boolean ignoreStreamPrefix) |
boolean |
ExprIdentNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprGroupingNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprGroupingIdNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprCurrentEvaluationContextNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprContextPropertyNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprConstantNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
static List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(ExprNode[] exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(ExprNode[] exprNodes) |
static List<Pair<Integer,String>> |
ExprNodeUtility.getExpressionProperties(ExprNode exprNode,
boolean visitAggregateNodes)
Walk expression returning properties used.
|
static Class[] |
ExprNodeUtility.getExprResultTypes(ExprNode[] nodes) |
static ExprForge[] |
ExprNodeUtility.getForges(ExprNode[] exprNodes) |
static ExprNodePropOrStreamSet |
ExprNodeUtility.getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes) |
static String[] |
ExprNodeUtility.getIdentResolvedPropertyNames(ExprNode[] nodes) |
static Set<Integer> |
ExprNodeUtility.getIdentStreamNumbers(ExprNode child) |
static Set<String> |
ExprNodeUtility.getPropertyNamesIfAllProps(ExprNode[] expressions) |
static void |
ExprNodeUtility.getValidatedSubtree(ExprNodeOrigin origin,
ExprNode[][] exprNode,
ExprValidationContext validationContext) |
static void |
ExprNodeUtility.getValidatedSubtree(ExprNodeOrigin origin,
ExprNode[] exprNode,
ExprValidationContext validationContext) |
static ExprNode |
ExprNodeUtility.getValidatedSubtree(ExprNodeOrigin origin,
ExprNode exprNode,
ExprValidationContext validationContext)
Validates the expression node subtree that has this
node as root.
|
static boolean |
ExprNodeUtility.hasRemoveStreamForAggregations(ExprNode child,
StreamTypeService streamTypeService,
boolean unidirectionalJoin)
Returns true if all properties within the expression are witin data window'd streams.
|
static boolean |
ExprNodeUtility.isConstantValueExpr(ExprNode exprNode) |
static String |
ExprNodeUtility.isMinimalExpression(ExprNode expression)
Check if the expression is minimal: does not have a subselect, aggregation and does not need view resources
|
static Object |
ExprNodeProxy.newInstance(String engineURI,
String statementName,
ExprNode exprNode) |
static void |
ExprNodeUtility.replaceChainChildNode(ExprNode nodeToReplace,
ExprNode newNode,
List<ExprChainedSpec> chainSpec) |
static void |
ExprNodeUtility.replaceChildNode(ExprNode parentNode,
ExprNode nodeToReplace,
ExprNode newNode) |
void |
ExprNodeBase.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
void |
ExprNode.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
void |
ExprNodeBase.setChildNode(int index,
ExprNode newNode) |
void |
ExprNode.setChildNode(int index,
ExprNode newNode) |
void |
ExprNodeBase.setChildNodes(ExprNode... nodes) |
void |
ExprNode.setChildNodes(ExprNode... nodes) |
static void |
ExprNodeUtility.toExpressionString(ExprNode node,
StringWriter buffer) |
static String[] |
ExprNodeUtility.toExpressionStringMinPrecedenceAsArray(ExprNode[] nodes) |
static String |
ExprNodeUtility.toExpressionStringMinPrecedenceAsList(ExprNode[] nodes) |
static void |
ExprNodeUtility.toExpressionStringMinPrecedenceAsList(ExprNode[] nodes,
StringWriter writer) |
static String |
ExprNodeUtility.toExpressionStringMinPrecedenceSafe(ExprNode node) |
static void |
ExprNodeUtility.toExpressionStringParameterList(ExprNode[] childNodes,
StringWriter buffer) |
static void |
ExprNodeUtility.toExpressionStringParams(StringWriter writer,
ExprNode[] params) |
static String[] |
ExprNodeUtility.toExpressionStringsMinPrecedence(ExprNode[] expressions) |
static void |
ExprNodeUtility.toExpressionStringWFunctionName(String functionName,
ExprNode[] childNodes,
StringWriter writer) |
static QueryGraph |
ExprNodeUtility.validateFilterGetQueryGraphSafe(ExprNode filterExpression,
StatementContext statementContext,
StreamTypeServiceImpl typeService) |
static void |
ExprNodeUtility.validateFilterWQueryGraphSafe(QueryGraph queryGraph,
ExprNode filterExpression,
StatementContext statementContext,
StreamTypeServiceImpl typeService) |
static void |
ExprNodeUtility.validateNoSpecialsGroupByExpressions(ExprNode[] groupByNodes) |
static void |
ExprNodeUtility.validatePlainExpression(ExprNodeOrigin origin,
ExprNode expression) |
static void |
ExprNodeUtility.validatePlainExpression(ExprNodeOrigin origin,
ExprNode[] expressions) |
static ExprNode |
ExprNodeUtility.validateSimpleGetSubtree(ExprNodeOrigin origin,
ExprNode expression,
StatementContext statementContext,
EventType optionalEventType,
boolean allowBindingConsumption) |
Modifier and Type | Method and Description |
---|---|
void |
ExprNodeBase.addChildNodes(Collection<ExprNode> childNodeColl) |
void |
ExprNode.addChildNodes(Collection<ExprNode> childNodes)
Adds child nodes.
|
static void |
ExprNodeUtility.applyFilterExpressionsIterable(Iterable<EventBean> iterable,
List<ExprNode> filterExpressions,
ExprEvaluatorContext exprEvaluatorContext,
Collection<EventBean> eventsInWindow) |
static ExprAndNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(Collection<ExprNode> nodes) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAndWhenNeeded(Collection<ExprNode> nodes) |
static ExprEvaluator[] |
ExprNodeUtility.crontabScheduleValidate(ExprNodeOrigin origin,
List<ExprNode> scheduleSpecExpressionList,
StatementContext context,
boolean allowBindingConsumption) |
static boolean |
ExprNodeUtility.deepEquals(List<ExprNode> one,
List<ExprNode> two) |
static boolean |
ExprNodeUtility.deepEquals(List<ExprNode> one,
List<ExprNode> two) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(List<ExprNode> exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(List<ExprNode> childNodes) |
static Class[] |
ExprNodeUtility.getExprResultTypes(List<ExprNode> expressions) |
static Map<String,ExprNamedParameterNode> |
ExprNodeUtility.getNamedExpressionsHandleDups(List<ExprNode> parameters) |
static ExprNodePropOrStreamSet |
ExprNodeUtility.getNonAggregatedProps(EventType[] types,
List<ExprNode> exprNodes,
ContextPropertyRegistry contextPropertyRegistry) |
static boolean |
ExprNodeUtility.hasStreamSelect(List<ExprNode> exprNodes) |
static boolean |
ExprNodeUtility.isAllConstants(List<ExprNode> parameters) |
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) |
void |
ExprChainedSpec.setParameters(List<ExprNode> parameters) |
static ExprNode[] |
ExprNodeUtility.toArray(Collection<ExprNode> expressions) |
static void |
ExprNodeUtility.toExpressionStringIncludeParen(List<ExprNode> parameters,
StringWriter buffer) |
static void |
ExprNodeUtility.toExpressionStringParameterList(List<ExprNode> parameters,
StringWriter buffer) |
Constructor and Description |
---|
ExprNodePropOrStreamExprDesc(int streamNum,
ExprNode originator) |
ExprNodeProxy(String engineURI,
String statementName,
ExprNode exprNode) |
ExprNodeValidated(ExprNode inner)
Ctor.
|
Constructor and Description |
---|
ExprChainedSpec(String name,
List<ExprNode> parameters,
boolean property) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprDotNode
Represents an Dot-operator expression, for use when "(expression).method(...).method(...)"
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAppDotMethodImpl |
class |
ExprDotNodeImpl
Represents an Dot-operator expression, for use when "(expression).method(...).method(...)"
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDotNodeForgeStaticMethod.getForgeRenderable() |
ExprNode |
ExprDotNodeForgePropertyExpr.getForgeRenderable() |
ExprNode |
ExprDotNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprAppDotMethodImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ExprDotNodeImpl.getAdditionalNodes() |
Modifier and Type | Method and Description |
---|---|
void |
ExprDotNodeImpl.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
boolean |
ExprDotNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprAppDotMethodImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
static ExprDotEnumerationSourceForge |
ExprDotNodeUtility.getEnumerationSource(ExprNode inputExpression,
StreamTypeService streamTypeService,
EventAdapterService eventAdapterService,
int statementId,
boolean hasEnumerationMethod,
boolean disablePropertyExpressionEventCollCache) |
void |
ExprDotNodeImpl.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
Constructor and Description |
---|
ExprDotNodeForgeStaticMethod(ExprNode parent,
boolean isReturnsConstantResult,
String statementName,
String classOrPropertyName,
net.sf.cglib.reflect.FastMethod staticMethod,
ExprForge[] childForges,
boolean isConstantParameters,
ExprDotForge[] chainForges,
ExprDotStaticMethodWrap resultWrapLambda,
boolean rethrowExceptions,
Object targetObject) |
Modifier and Type | Class and Description |
---|---|
class |
ExprCaseNode
Represents the case-when-then-else control flow function is an expression tree.
|
class |
ExprCastNode
Represents the CAST(expression, type) function is an expression tree.
|
class |
ExprCoalesceNode
Represents the COALESCE(a,b,...) function is an expression tree.
|
class |
ExprInstanceofNode
Represents the INSTANCEOF(a,b,...) function is an expression tree.
|
class |
ExprIStreamNode
Represents the RSTREAM() function in an expression tree.
|
class |
ExprMinMaxRowNode
Represents the MAX(a,b) and MIN(a,b) functions is an expression tree.
|
class |
ExprPlugInSingleRowNode
Represents an invocation of a plug-in single-row function in the expression tree.
|
class |
ExprPropertyExistsNode
Represents the EXISTS(property) function in an expression tree.
|
class |
ExprTypeofNode
Represents the TYPEOF(a) function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTypeofNodeForgeStreamEvent.getForgeRenderable() |
ExprNode |
ExprTypeofNodeForgeFragmentType.getForgeRenderable() |
ExprNode |
ExprPropertyExistsNode.getForgeRenderable() |
ExprNode |
ExprIStreamNode.getForgeRenderable() |
ExprNode |
ExprCaseNodeForge.getOptionalCompareExprNode() |
ExprNode |
ExprCaseNode.CaseAnalysis.getOptionalCompareExprNode() |
ExprNode |
ExprCaseNodeForge.getOptionalElseExprNode() |
ExprNode |
ExprCaseNode.CaseAnalysis.getOptionalElseExprNode() |
ExprNode |
ExprTypeofNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPropertyExistsNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPlugInSingleRowNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprMinMaxRowNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprIStreamNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprInstanceofNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCoalesceNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCastNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCaseNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ExprPlugInSingleRowNode.getAdditionalNodes() |
List<UniformPair<ExprNode>> |
ExprCaseNodeForge.getWhenThenNodeList() |
List<UniformPair<ExprNode>> |
ExprCaseNode.CaseAnalysis.getWhenThenNodeList() |
Modifier and Type | Method and Description |
---|---|
void |
ExprPlugInSingleRowNode.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
protected static CodegenExpression |
ExprCaseNodeForgeEvalSyntax1.codegenToType(ExprCaseNodeForge forge,
ExprNode node,
CodegenContext context,
CodegenParamSetExprPremade params) |
boolean |
ExprTypeofNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprPropertyExistsNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprPlugInSingleRowNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprMinMaxRowNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprIStreamNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprInstanceofNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprCoalesceNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprCastNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprCaseNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
void |
ExprPlugInSingleRowNode.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
Constructor and Description |
---|
CaseAnalysis(List<UniformPair<ExprNode>> whenThenNodeList,
ExprNode optionalCompareExprNode,
ExprNode optionalElseExprNode) |
Constructor and Description |
---|
CaseAnalysis(List<UniformPair<ExprNode>> whenThenNodeList,
ExprNode optionalCompareExprNode,
ExprNode optionalElseExprNode) |
Modifier and Type | Class and Description |
---|---|
class |
ExprAvedevNode
Represents the avedev(...) aggregate function is an expression tree.
|
class |
ExprAvgNode
Represents the avg(...) aggregate function is an expression tree.
|
class |
ExprCountEverNode
Represents the "countever" aggregate function is an expression tree.
|
class |
ExprCountNode
Represents the count(...) and count(*) and count(distinct ...) aggregate function is an expression tree.
|
class |
ExprFirstEverNode
Represents the "firstever" aggregate function is an expression tree.
|
class |
ExprLastEverNode
Represents the "lastever" aggregate function is an expression tree.
|
class |
ExprLeavingAggNode
Represents the leaving() aggregate function is an expression tree.
|
class |
ExprMedianNode
Represents the median(...) aggregate function is an expression tree.
|
class |
ExprMinMaxAggrNode
Represents the min/max(distinct? ...) aggregate function is an expression tree.
|
class |
ExprNthAggNode
Represents the nth(...) and aggregate function is an expression tree.
|
class |
ExprPlugInAggNode
Represents a custom aggregation function in an expresson tree.
|
class |
ExprRateAggNode
Represents the rate(...) and aggregate function is an expression tree.
|
class |
ExprStddevNode
Represents the stddev(...) aggregate function is an expression tree.
|
class |
ExprSumNode
Represents the sum(...) aggregate function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ExprMethodAggUtil.getDefaultEvaluator(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
static ExprEvaluator |
ExprMethodAggUtil.getMultiNodeEvaluator(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAndNode
Represents an And-condition.
|
interface |
ExprBetweenNode
Represents the between-clause function in an expression tree.
|
interface |
ExprEqualsNode
Represents an equals (=, !=, <>, is, is not) comparator in a filter expressiun tree.
|
interface |
ExprInNode
Represents the in-clause (set check) function in an expression tree.
|
interface |
ExprRelationalOpNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAndNodeImpl
Represents an And-condition.
|
class |
ExprArrayNode
Represents an array in a filter expressiun tree.
|
class |
ExprBetweenNodeImpl
Represents the between-clause function in an expression tree.
|
class |
ExprBitWiseNode
Represents the bit-wise operators in an expression tree.
|
class |
ExprConcatNode
Represents a string concatenation.
|
class |
ExprEqualsAllAnyNode
Represents an equals-for-group (= ANY/ALL/SOME (expression list)) comparator in a expression tree.
|
class |
ExprEqualsNodeImpl
Represents an equals (=) comparator in a filter expressiun tree.
|
class |
ExprInNodeImpl
Represents the in-clause (set check) function in an expression tree.
|
class |
ExprLikeNode
Represents the like-clause in an expression tree.
|
class |
ExprMathNode
Represents a simple Math (+/-/divide/*) in a filter expression tree.
|
class |
ExprNewInstanceNode
Represents the "new Class(...)" operator in an expression tree.
|
class |
ExprNewStructNode
Represents the "new {...}" operator in an expression tree.
|
class |
ExprNotNode
Represents a NOT expression in an expression tree.
|
class |
ExprOrNode
Represents an OR expression in a filter expression tree.
|
class |
ExprRegexpNode
Represents the regexp-clause in an expression tree.
|
class |
ExprRelationalOpAllAnyNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
class |
ExprRelationalOpNodeImpl
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprOrNode.getForgeRenderable() |
ExprNode |
ExprNotNode.getForgeRenderable() |
ExprNode |
ExprRelationalOpNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprRelationalOpAllAnyNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprRegexpNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprOrNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNotNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNewStructNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNewInstanceNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprMathNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprLikeNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprInNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprEqualsNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprEqualsAllAnyNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprConcatNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprBitWiseNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprBetweenNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprArrayNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprAndNodeImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
ExprBitWiseNodeForgeEval.codegen(ExprBitWiseNodeForge forge,
CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode lhs,
ExprNode rhs) |
static String |
ExprEqualsNodeForgeCoercionEval.codegen(ExprEqualsNodeForgeCoercion forge,
CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode lhs,
ExprNode rhs) |
static String |
ExprLikeNodeForgeConstEval.codegen(ExprLikeNodeForgeConst forge,
ExprNode lhs,
CodegenContext context,
CodegenParamSetExprPremade params) |
static String |
ExprLikeNodeFormNonconstEval.codegen(ExprLikeNodeForgeNonconst forge,
ExprNode lhs,
ExprNode pattern,
ExprNode optionalEscape,
CodegenContext context,
CodegenParamSetExprPremade params) |
static String |
ExprMathNodeForgeEval.codegen(ExprMathNodeForge forge,
CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode lhs,
ExprNode rhs) |
static String |
ExprRegexpNodeForgeConstEval.codegen(ExprRegexpNodeForgeConst forge,
ExprNode lhs,
CodegenContext context,
CodegenParamSetExprPremade params) |
static String |
ExprRegexpNodeForgeNonconstEval.codegen(ExprRegexpNodeForgeNonconst forge,
ExprNode lhs,
ExprNode pattern,
CodegenContext context,
CodegenParamSetExprPremade params) |
boolean |
ExprRelationalOpNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprRelationalOpAllAnyNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprRegexpNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprOrNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNotNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNewStructNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNewInstanceNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprMathNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprLikeNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprInNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprEqualsNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprEqualsAllAnyNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprConcatNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprBitWiseNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprBetweenNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprArrayNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprAndNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPreviousMatchRecognizeNode
Represents the 'prev' previous event function in match-recognize "define" item.
|
class |
ExprPreviousNode
Represents the 'prev' previous event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprPreviousNode.getForgeRenderable() |
ExprNode |
ExprPreviousMatchRecognizeNode.getForgeRenderable() |
ExprNode |
ExprPreviousNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPreviousMatchRecognizeNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprPreviousNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprPreviousMatchRecognizeNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPriorNode
Represents the 'prior' prior event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprPriorNode.getForgeRenderable() |
ExprNode |
ExprPriorNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprPriorNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprSubselectAllSomeAnyNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectExistsNode
Represents an exists-subselect in an expression tree.
|
class |
ExprSubselectInNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectRowNode
Represents a subselect in an expression tree.
|
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
ExprSubselectNode.selectClause
The validated select clause.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
ExprSubselectNode.getSelectClause()
Returns the select clause or null if none.
|
ExprNode |
ExprSubselectNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprSubselectNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
void |
ExprSubselectNode.setSelectClause(ExprNode[] selectClause,
EngineImportService engineImportService,
String statementName)
Sets the validates select clause
|
Modifier and Type | Class and Description |
---|---|
class |
ExprTableAccessNode |
class |
ExprTableAccessNodeKeys |
class |
ExprTableAccessNodeSubprop |
class |
ExprTableAccessNodeSubpropAccessor |
class |
ExprTableAccessNodeTopLevel |
class |
ExprTableIdentNode |
class |
ExprTableIdentNodeSubpropAccessor |
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTableIdentNode.getForgeRenderable() |
ExprNode |
ExprTableIdentNodeSubpropAccessor.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTableIdentNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTableAccessNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprTableIdentNodeSubpropAccessor.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTableIdentNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTableAccessNode.equalsNode(ExprNode o,
boolean ignoreStreamPrefix) |
static void |
ExprTableNodeUtil.validateExpressions(String tableName,
Class[] providedTypes,
String providedName,
ExprNode[] providedExpr,
Class[] expectedTypes,
String expectedName) |
Constructor and Description |
---|
ExprTableAccessNodeSubpropAccessor(String tableName,
String subpropName,
ExprNode aggregateAccessMultiValueNode) |
ExprTableIdentNodeSubpropAccessor(int streamNum,
String optionalStreamName,
TableMetadataColumnAggregation tableAccessColumn,
ExprNode aggregateAccessMultiValueNode) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprTimePeriod
Expression representing a time period.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprTimePeriodImpl
Expression representing a time period.
|
class |
ExprTimestampNode
Represents the CURRENT_TIMESTAMP() function or reserved keyword in an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTimestampNode.getForgeRenderable() |
ExprNode |
ExprTimestampNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTimePeriodImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprTimestampNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTimePeriodImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ExprNodeViewResourceVisitor.getExprNodes()
Returns the list of expression nodes requiring view resources.
|
List<Pair<ExprNode,ExprIdentNode>> |
ExprNodeIdentifierCollectVisitorWContainer.getExprProperties()
Returns list of event property stream numbers and names that uniquely identify which
property is from whcih stream, and the name of each.
|
List<Pair<ExprNode,ExprGroupingIdNode>> |
ExprNodeGroupingVisitorWParent.getGroupingIdNodes() |
List<Pair<ExprNode,ExprGroupingNode>> |
ExprNodeGroupingVisitorWParent.getGroupingNodes() |
List<Pair<ExprNode,ExprIdentNode>> |
ExprNodeIdentVisitorWParent.getIdentNodes() |
List<Pair<ExprNode,ExprPreviousNode>> |
ExprNodePreviousVisitorWParent.getPrevious()
Returns the pair of previous nodes and their parent expression.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ExprNodeVisitorWithParent.isVisit(ExprNode exprNode)
Allows visitor to indicate whether to visit a given node.
|
boolean |
ExprNodeVisitor.isVisit(ExprNode exprNode)
Allows visitor to indicate whether to visit a given node.
|
boolean |
ExprNodeViewResourceVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeVariableVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeTableAccessVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeTableAccessFinderVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSummaryVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSubselectDeclaredNoTraverseVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSubselectDeclaredDotVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamUseCollectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamSelectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamRequiredVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodePreviousVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierCollectVisitorWContainer.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierCollectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierAndStreamRefVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeGroupingVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeDeclaredVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeContextPropertiesVisitor.isVisit(ExprNode exprNode) |
void |
ExprNodeVisitor.visit(ExprNode exprNode)
Visit the given expression node.
|
void |
ExprNodeViewResourceVisitor.visit(ExprNode exprNode) |
void |
ExprNodeVariableVisitor.visit(ExprNode exprNode) |
void |
ExprNodeTableAccessVisitor.visit(ExprNode exprNode) |
void |
ExprNodeTableAccessFinderVisitor.visit(ExprNode exprNode) |
void |
ExprNodeSummaryVisitor.visit(ExprNode exprNode) |
void |
ExprNodeSubselectDeclaredDotVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamUseCollectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamSelectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamRequiredVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierCollectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierAndStreamRefVisitor.visit(ExprNode exprNode) |
void |
ExprNodeDeclaredVisitor.visit(ExprNode exprNode) |
void |
ExprNodeContextPropertiesVisitor.visit(ExprNode exprNode) |
void |
ExprNodeVisitorWithParent.visit(ExprNode exprNode,
ExprNode parentExprNode)
Visit the given expression node.
|
void |
ExprNodeSubselectDeclaredNoTraverseVisitor.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodePreviousVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodeIdentVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodeIdentifierCollectVisitorWContainer.visit(ExprNode exprNode,
ExprNode containerExprNode) |
void |
ExprNodeGroupingVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
EngineImportApplicationDotMethodBase.getLhs() |
ExprNode[] |
EngineImportApplicationDotMethodBase.getRhs() |
ExprNode |
EngineImportApplicationDotMethodBase.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
protected ExprForge |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprForge |
EngineImportApplicationDotMethodBase.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprForge |
EngineImportApplicationDotMethodBase.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
AdvancedIndexConfigContextPartition |
AdvancedIndexFactoryProviderQuadTree.validateConfigureFilterIndex(String indexName,
String indexTypeName,
ExprNode[] parameters,
ExprValidationContext validationContext) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderPointRegionQuadTree.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderPointRegionQuadTree.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderMXCIFQuadTree.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderMXCIFQuadTree.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
protected static void |
AdvancedIndexFactoryProviderQuadTree.validateParameters(String indexTypeName,
ExprNode[] parameters) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategyFactoryQuadTree |
EventAdvancedIndexFactoryQuadTree.getSubordinateLookupStrategy(String operationName,
Map<Integer,ExprNode> positionalExpressions,
boolean isNWOnTrigger,
int numOuterstreams) |
boolean |
EventAdvancedIndexFactoryQuadTreePointRegion.providesIndexForOperation(String operationName,
Map<Integer,ExprNode> value) |
boolean |
EventAdvancedIndexFactoryQuadTreeMXCIF.providesIndexForOperation(String operationName,
Map<Integer,ExprNode> value) |
Modifier and Type | Method and Description |
---|---|
static void |
AdvancedIndexValidationHelper.validateColumnReturnTypeNumber(String indexTypeName,
int colnum,
ExprNode expr,
String name) |
AdvancedIndexConfigContextPartition |
AdvancedIndexFactoryProvider.validateConfigureFilterIndex(String indexName,
String indexTypeName,
ExprNode[] parameters,
ExprValidationContext validationContext) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProvider.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProvider.validateEventIndex(String indexName,
String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
static void |
AdvancedIndexValidationHelper.validateParameterReturnType(Class expectedReturnType,
String indexTypeName,
int paramnum,
ExprNode expr,
String name) |
static void |
AdvancedIndexValidationHelper.validateParameterReturnTypeNumber(String indexTypeName,
int paramnum,
ExprNode expr,
String name) |
Constructor and Description |
---|
FilterExprAnalyzerAffectorIndexProvision(String operationName,
ExprNode[] indexExpressions,
List<Pair<ExprNode,int[]>> keyExpressions,
int streamNumIndex) |
Constructor and Description |
---|
FilterExprAnalyzerAffectorIndexProvision(String operationName,
ExprNode[] indexExpressions,
List<Pair<ExprNode,int[]>> keyExpressions,
int streamNumIndex) |
Modifier and Type | Method and Description |
---|---|
static JoinSetComposerPrototype |
JoinSetComposerPrototypeFactory.makeComposerPrototype(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery,
boolean allowIndexInit) |
Constructor and Description |
---|
HistoricalIndexLookupStrategyInKeywordMulti(int lookupStream,
ExprNode expression) |
HistoricalIndexLookupStrategyInKeywordSingle(int lookupStream,
ExprNode[] expressions) |
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) |
Constructor and Description |
---|
IndexedTableLookupStrategySingleExpr(ExprNode exprNode,
int streamNum,
PropertyIndexedEventTableSingle index,
LookupStrategyDesc strategyDesc) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExcludePlanHint.filter(int streamLookup,
int streamIndexed,
ExcludePlanFilterOperatorType opType,
ExprNode... exprNodes) |
static EventBean |
ExcludePlanHintExprUtil.toEvent(int fromStreamnum,
int toStreamnum,
String fromStreamname,
String toStreamname,
String opname,
ExprNode[] expressions) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
QueryGraphValueEntryRangeIn.getExprEnd() |
ExprNode |
QueryGraphValueEntryRangeRelOp.getExpression() |
ExprNode[] |
QueryGraphValueEntryRangeRelOp.getExpressions() |
ExprNode[] |
QueryGraphValueEntryRangeIn.getExpressions() |
abstract ExprNode[] |
QueryGraphValueEntryRange.getExpressions() |
ExprNode[] |
InKeywordTableLookupPlanSingleIdx.getExpressions() |
ExprNode[] |
QueryGraphValueEntryCustomKey.getExprNodes() |
ExprNode |
QueryGraphValueEntryRangeIn.getExprStart() |
ExprNode[] |
QueryGraphValuePairInKWMultiIdx.getIndexed() |
ExprNode[] |
QueryGraphValueDesc.getIndexExprs() |
ExprNode |
QueryGraphValueEntryInKeywordMultiIdx.getKeyExpr() |
ExprNode |
QueryGraphValueEntryHashKeyed.getKeyExpr() |
ExprNode |
InKeywordTableLookupPlanMultiIdx.getKeyExpr() |
ExprNode[] |
QueryGraphValueEntryInKeywordSingleIdx.getKeyExprs() |
Modifier and Type | Method and Description |
---|---|
Map<Integer,ExprNode> |
QueryGraphValueEntryCustomOperation.getPositionalExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
QueryGraphValue.addCustom(ExprNode[] indexExpressions,
String operationName,
int expressionPosition,
ExprNode expression) |
void |
QueryGraphValue.addCustom(ExprNode[] indexExpressions,
String operationName,
int expressionPosition,
ExprNode expression) |
void |
QueryGraph.addCustomIndex(String operationName,
ExprNode[] indexExpressions,
List<Pair<ExprNode,int[]>> streamKeys,
int streamValue) |
void |
QueryGraphValue.addInKeywordMultiIdx(ExprNode testPropExpr,
ExprNode[] setProps) |
void |
QueryGraphValue.addInKeywordMultiIdx(ExprNode testPropExpr,
ExprNode[] setProps) |
void |
QueryGraphValue.addInKeywordSingleIdx(ExprNode testPropIdent,
ExprNode[] setPropExpr) |
void |
QueryGraphValue.addInKeywordSingleIdx(ExprNode testPropIdent,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetMultiIndex(int testStreamNum,
ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetMultiIndex(int testStreamNum,
ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetMultiIndexUnkeyed(ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetMultiIndexUnkeyed(ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetSingleIndex(int testStreamNum,
ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetSingleIndex(int testStreamNum,
ExprNode testPropExpr,
int setStreamNum,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetSingleIndexUnkeyed(int testStreamNum,
ExprNode testPropExpr,
ExprNode[] setPropExpr) |
void |
QueryGraph.addInSetSingleIndexUnkeyed(int testStreamNum,
ExprNode testPropExpr,
ExprNode[] setPropExpr) |
void |
QueryGraphValue.addKeyedExpr(ExprIdentNode indexedPropIdent,
ExprNode exprNodeNoIdent) |
void |
QueryGraph.addKeyedExpression(int indexedStream,
ExprIdentNode indexedProp,
int keyExprStream,
ExprNode exprNodeNoIdent) |
void |
QueryGraphValue.addRange(QueryGraphRangeEnum rangeType,
ExprNode propertyStart,
ExprNode propertyEnd,
ExprIdentNode propertyValueIdent) |
void |
QueryGraph.addRangeExpr(int indexedStream,
ExprIdentNode indexedProp,
ExprNode startNode,
Integer optionalStartStreamNum,
ExprNode endNode,
Integer optionalEndStreamNum,
QueryGraphRangeEnum rangeOp) |
void |
QueryGraph.addRelationalOp(int indexedStream,
ExprIdentNode indexedProp,
Integer keyStreamNum,
ExprNode exprNodeNoIdent,
RelationalOpEnum relationalOpEnum) |
void |
QueryGraphValue.addRelOp(ExprNode propertyKey,
QueryGraphRangeEnum op,
ExprIdentNode propertyValueIdent,
boolean isBetweenOrIn) |
void |
QueryGraphValue.addUnkeyedExpr(ExprIdentNode indexedPropIdent,
ExprNode exprNodeNoIdent) |
void |
QueryGraph.addUnkeyedExpression(int indexedStream,
ExprIdentNode indexedProp,
ExprNode exprNodeNoIdent) |
static void |
FilterExprAnalyzer.analyze(ExprNode topNode,
QueryGraph queryGraph,
boolean isOuterJoin)
Analyzes filter expression to build query graph model.
|
static Class |
CoercionUtil.getCoercionTypeRangeIn(Class valuePropType,
ExprNode exprStart,
ExprNode exprEnd) |
static SubordPropPlan |
QueryPlanIndexBuilder.getJoinProps(ExprNode filterExpr,
int outsideStreamCount,
EventType[] allStreamTypesZeroIndexed,
ExcludePlanHint excludePlanHint) |
Modifier and Type | Method and Description |
---|---|
void |
QueryGraph.addCustomIndex(String operationName,
ExprNode[] indexExpressions,
List<Pair<ExprNode,int[]>> streamKeys,
int streamValue) |
Modifier and Type | Method and Description |
---|---|
static void |
RangeFilterAnalyzer.apply(ExprNode target,
ExprNode start,
ExprNode end,
boolean includeStart,
boolean includeEnd,
boolean isNot,
QueryGraph queryGraph) |
static EligibilityDesc |
EligibilityUtil.verifyInputStream(ExprNode expression,
int indexedStream) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
SubordPropInKeywordMultiIndex.getExpression() |
ExprNode[] |
SubordPropInKeywordSingleIndex.getExpressions() |
ExprNode[] |
AdvancedIndexDesc.getIndexedExpressions() |
Modifier and Type | Method and Description |
---|---|
static SubordTableLookupStrategyFactory |
SubordinateTableLookupStrategyUtil.getLookupStrategy(EventType[] outerStreamTypesZeroIndexed,
List<SubordPropHashKey> hashKeys,
CoercionDesc hashKeyCoercionTypes,
List<SubordPropRangeKey> rangeKeys,
CoercionDesc rangeKeyCoercionTypes,
ExprNode[] inKeywordSingleIdxKeys,
ExprNode inKeywordMultiIdxKey,
boolean isNWOnTrigger) |
static SubordTableLookupStrategyFactory |
SubordinateTableLookupStrategyUtil.getLookupStrategy(EventType[] outerStreamTypesZeroIndexed,
List<SubordPropHashKey> hashKeys,
CoercionDesc hashKeyCoercionTypes,
List<SubordPropRangeKey> rangeKeys,
CoercionDesc rangeKeyCoercionTypes,
ExprNode[] inKeywordSingleIdxKeys,
ExprNode inKeywordMultiIdxKey,
boolean isNWOnTrigger) |
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) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategyFactoryQuadTree |
EventAdvancedIndexFactory.getSubordinateLookupStrategy(String operationName,
Map<Integer,ExprNode> expressions,
boolean isNWOnTrigger,
int numOuterstreams) |
boolean |
EventAdvancedIndexFactory.providesIndexForOperation(String operationName,
Map<Integer,ExprNode> expressions) |
Constructor and Description |
---|
AdvancedIndexDesc(String indexTypeName,
ExprNode[] indexedExpressions) |
SubordInKeywordMultiTableLookupStrategyFactory(boolean isNWOnTrigger,
int streamCountOuter,
ExprNode exprNode) |
SubordInKeywordSingleTableLookupStrategyFactory(boolean isNWOnTrigger,
int streamCountOuter,
ExprNode[] exprNodes) |
SubordPropInKeywordMultiIndex(String[] indexedProp,
Class coercionType,
ExprNode expression) |
SubordPropInKeywordSingleIndex(String indexedProp,
Class coercionType,
ExprNode[] expressions) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
DotMethodFPProvidedParam.getExpression() |
Modifier and Type | Method and Description |
---|---|
static DotMethodFPProvided |
DotMethodUtil.getProvidedFootprint(List<ExprNode> parameters) |
Constructor and Description |
---|
DotMethodFPProvidedParam(int lambdaParamNum,
Class returnType,
ExprNode expression) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
NamedWindowConsumerDesc.getFilterExpressions() |
Modifier and Type | Method and Description |
---|---|
EventBean[] |
NamedWindowTailViewInstance.snapshotDelete(QueryGraph queryGraph,
ExprNode filterExpr,
Annotation[] annotations) |
Collection<EventBean> |
NamedWindowTailViewInstance.snapshotNoLockWithFilter(QueryGraph queryGraph,
Annotation[] annotations,
ExprNode filterExpr,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
NamedWindowTailViewInstance.snapshotUpdate(QueryGraph queryGraph,
ExprNode optionalWhereClause,
EventBeanUpdateHelper updateHelper,
Annotation[] annotations) |
Constructor and Description |
---|
NamedWindowConsumerDesc(ExprNode[] filterExpressions,
ExprEvaluator[] filterEvaluators,
PropertyEvaluator optPropertyEvaluator,
AgentInstanceContext agentInstanceContext) |
NamedWindowOnMergeMatch(ExprNode optionalCond,
List<NamedWindowOnMergeAction> actions,
EngineImportService engineImportService,
String statementName) |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ASTExprHelper.exprCollectSubNodesPerNode(List<EsperEPL2GrammarParser.ExpressionContext> expression,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprNode |
ASTExprHelper.mathGetExpr(org.antlr.v4.runtime.tree.ParseTree ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation configurationInformation) |
static ExprNode |
ASTExprHelper.resolvePropertyOrVariableIdentifier(String identifier,
VariableService variableService,
StatementSpecRaw spec) |
static ExprNode |
ASTAggregationHelper.tryResolveAsAggregation(EngineImportService engineImportService,
boolean distinct,
String functionName,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
String engineURI) |
Modifier and Type | Method and Description |
---|---|
static List<ExprNode> |
ASTExprHelper.exprCollectSubNodes(org.antlr.v4.runtime.tree.Tree parentNode,
int startIndex,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static List<ExprNode> |
ASTLibFunctionHelper.getExprNodesLibFunc(EsperEPL2GrammarParser.LibFunctionArgsContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
Modifier and Type | Method and Description |
---|---|
static void |
ASTExprHelper.addOptionalNumber(ExprNode exprNode,
EsperEPL2GrammarParser.NumberContext number) |
static void |
ASTExprHelper.addOptionalSimpleProperty(ExprNode exprNode,
org.antlr.v4.runtime.Token token,
VariableService variableService,
StatementSpecRaw spec) |
static void |
ASTExprHelper.exprCollectAddSingle(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodes(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesAddParentNode(ExprNode exprNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesExpressionCtx(ExprNode parentNode,
List<EsperEPL2GrammarParser.ExpressionContext> expressionContexts,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static boolean |
ASTMatchUntilHelper.validate(ExprNode lowerBounds,
ExprNode upperBounds,
boolean isAllowLowerZero)
Validate.
|
Modifier and Type | Method and Description |
---|---|
static OutputLimitSpec |
ASTOutputLimitHelper.buildOutputLimitSpec(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.OutputLimitContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
String engineURI,
TimeProvider timeProvider,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ASTExprHelper.exprCollectAddSingle(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodes(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesAddParentNode(ExprNode exprNode,
org.antlr.v4.runtime.tree.Tree node,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesExpressionCtx(ExprNode parentNode,
List<EsperEPL2GrammarParser.ExpressionContext> expressionContexts,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static List<ExprNode> |
ASTExprHelper.exprCollectSubNodes(org.antlr.v4.runtime.tree.Tree parentNode,
int startIndex,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprNode[] |
ASTExprHelper.exprCollectSubNodesPerNode(List<EsperEPL2GrammarParser.ExpressionContext> expression,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static List<CreateTableColumn> |
ASTTableHelper.getColumns(List<EsperEPL2GrammarParser.CreateTableColumnContext> ctxs,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
EngineImportService engineImportService) |
static List<ExprNode> |
ASTLibFunctionHelper.getExprNodesLibFunc(EsperEPL2GrammarParser.LibFunctionArgsContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static List<ExprChainedSpec> |
ASTLibFunctionHelper.getLibFuncChain(List<EsperEPL2GrammarParser.LibFunctionNoClassContext> ctxs,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprChainedSpec |
ASTLibFunctionHelper.getLibFunctionChainSpec(EsperEPL2GrammarParser.LibFunctionNoClassContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
protected static List<OnTriggerSetAssignment> |
ASTExprHelper.getOnTriggerSetAssignments(EsperEPL2GrammarParser.OnSetAssignmentListContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
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 |
ASTExprHelper.mathGetExpr(org.antlr.v4.runtime.tree.ParseTree ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation configurationInformation) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprAllParams(EsperEPL2GrammarParser.TimePeriodContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
StatementSpecRaw spec,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprJustSeconds(EsperEPL2GrammarParser.ExpressionContext expression,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static CreateIndexDesc |
ASTIndexHelper.walk(EsperEPL2GrammarParser.CreateIndexExprContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static CreateContextDesc |
ASTContextHelper.walkCreateContext(EsperEPL2GrammarParser.CreateContextExprContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
Map<org.antlr.v4.runtime.tree.Tree,EvalFactoryNode> astPatternNodeMap,
PropertyEvalSpec propertyEvalSpec,
FilterSpecRaw filterSpec) |
static Pair<ExpressionDeclItem,ExpressionScriptProvided> |
ASTExpressionDeclHelper.walkExpressionDecl(EsperEPL2GrammarParser.ExpressionDeclContext ctx,
List<String> scriptBodies,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
org.antlr.v4.runtime.CommonTokenStream tokenStream) |
static FilterSpecRaw |
ASTFilterSpecHelper.walkFilterSpec(EsperEPL2GrammarParser.EventFilterExpressionContext ctx,
PropertyEvalSpec propertyEvalSpec,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTGroupByHelper.walkGroupBy(EsperEPL2GrammarParser.GroupByListExprContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
List<GroupByClauseElement> groupByExpressions) |
static RowRegexExprRepeatDesc |
ASTMatchRecognizeHelper.walkOptionalRepeat(EsperEPL2GrammarParser.MatchRecogPatternRepeatContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
Modifier and Type | Method and Description |
---|---|
static EPType |
EPTypeHelper.optionalFromEnumerationExpr(int statementId,
EventAdapterService eventAdapterService,
ExprNode exprNode) |
Modifier and Type | Class and Description |
---|---|
class |
ExprNodeScript |
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprNodeScript.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ExprNodeScript.getAdditionalNodes() |
List<ExprNode> |
ExprNodeScript.getParameters() |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprNodeScript.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Constructor and Description |
---|
ExprNodeScript(String defaultDialect,
ExpressionScriptProvided script,
List<ExprNode> parameters) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
OutputLimitSpec.getAndAfterTerminateExpr() |
ExprNode |
CreateVariableDesc.getAssignment()
Returns the assignment expression, or null if none
|
ExprNode[] |
ContextDetailInitiatedTerminated.getDistinctExpressions() |
ExprNode |
MatchRecognizeMeasureItem.getExpr()
Returns the expression.
|
ExprNode |
GroupByClauseElementExpr.getExpr() |
ExprNode |
OnTriggerSetAssignment.getExpression()
Returns the expression providing the new variable value, or null if none
|
ExprNode |
MatchRecognizeDefineItem.getExpression()
Returns the expression.
|
ExprNode |
ContextDetailCategoryItem.getExpression() |
ExprNode |
OrderByItem.getExprNode()
Returns the order-by expression node.
|
ExprNode |
StatementSpecRaw.getFilterExprRootNode()
Gets the where clause.
|
ExprNode |
StatementSpecRaw.getFilterRootNode()
Returns the WHERE-clause root node of filter expression.
|
ExprNode |
StatementSpecCompiled.getFilterRootNode()
Returns the WHERE-clause root node of filter expression.
|
ExprNode[] |
GroupByClauseExpressions.getGroupByNodes() |
ExprNode |
StatementSpecRaw.getHavingExprRootNode()
Returns expression root node representing the having-clause, if present, or null if no having clause was supplied.
|
ExprNode |
StatementSpecCompiled.getHavingExprRootNode()
Returns expression root node representing the having-clause, if present, or null if no having clause was supplied.
|
ExprNode |
ExpressionDeclItem.getInner() |
ExprNode |
CreateWindowDesc.getInsertFilter()
Returns the expression to filter insert-from events, or null if none supplied.
|
ExprNode |
NewItem.getOptExpression() |
ExprNode |
CreateTableColumn.getOptExpression() |
ExprNode[] |
GroupByClauseExpressions.getOptHavingNodePerLevel() |
ExprNode |
OnTriggerMergeMatched.getOptionalMatchCond() |
ExprNode |
OnTriggerMergeEntry.getOptionalMatchCond() |
ExprNode |
UpdateDesc.getOptionalWhereClause()
Returns the where-clause if defined.
|
ExprNode |
PropertyEvalAtom.getOptionalWhereClause()
Returns the where clause, if specified.
|
ExprNode |
OnTriggerMergeAction.getOptionalWhereClause() |
ExprNode[][] |
GroupByClauseExpressions.getOptOrderByPerLevel() |
ExprNode[][] |
GroupByClauseExpressions.getSelectClausePerLevel() |
ExprNode |
SelectClauseExprRawSpec.getSelectExpression()
Returns the expression node representing the item in the select clause.
|
ExprNode |
SelectClauseExprCompiledSpec.getSelectExpression()
Returns the expression node representing the item in the select clause.
|
ExprNode |
PropertyEvalAtom.getSplitterExpression() |
ExprNode |
OutputLimitSpec.getWhenExpressionNode()
Returns the when-keyword trigger expression, or null if not using when.
|
ExprNode |
OnTriggerSplitStream.getWhereClause()
Returns the where clause or null if not defined
|
ExprNode |
OuterJoinDesc.makeExprNode(ExprEvaluatorContext exprEvaluatorContext)
Make an expression node that represents the outer join criteria as specified in the on-clause.
|
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
ContextDetailConditionCrontab.getCrontab() |
List<ExprNode> |
OutputLimitSpec.getCrontabAtSchedule()
Returns crontab parameters, or null if not using crontab-at output.
|
List<ExprNode> |
MethodStreamSpec.getExpressions()
Returns the parameter expressions.
|
List<ExprNode> |
GroupByClauseElementCombinedExpr.getExpressions() |
List<ExprNode> |
ForClauseItemSpec.getExpressions() |
List<ExprNode> |
CreateIndexItem.getExpressions() |
List<ExprNode> |
TableQueryStreamSpec.getFilterExpressions() |
List<ExprNode> |
NamedWindowConsumerStreamSpec.getFilterExpressions()
Returns list of filter expressions onto the named window, or no filter expressions if none defined.
|
List<ExprNode> |
FilterSpecRaw.getFilterExpressions()
Returns the list of filter expressions.
|
List<ExprNode> |
ObjectSpec.getObjectParameters()
Returns the list of object parameters.
|
List<ExprNode> |
CreateIndexItem.getParameters() |
List<ExprNode> |
MatchRecognizeSpec.getPartitionByExpressions()
Returns partition expressions.
|
Map<Integer,List<ExprNode>> |
StatementSpecRaw.getSqlParameters() |
Map<Integer,List<ExprNode>> |
StatementSpecCompiled.getSqlParameters() |
Modifier and Type | Method and Description |
---|---|
void |
OutputLimitSpec.setAndAfterTerminateExpr(ExprNode andAfterTerminateExpr) |
void |
MatchRecognizeMeasureItem.setExpr(ExprNode validated)
Sets the validated expression.
|
void |
OnTriggerSetAssignment.setExpression(ExprNode expression)
Sets the expression providing the new variable value
|
void |
MatchRecognizeDefineItem.setExpression(ExprNode validated)
Sets the validated expression
|
void |
StatementSpecRaw.setFilterExprRootNode(ExprNode filterExprRootNode)
Sets the where clause or null if none
|
void |
StatementSpecCompiled.setFilterExprRootNode(ExprNode optionalFilterNode)
Set the where clause filter node.
|
void |
StatementSpecRaw.setHavingExprRootNode(ExprNode havingExprRootNode)
Sets the having-clause filter expression node.
|
void |
StatementSpecCompiled.setHavingExprRootNode(ExprNode havingExprRootNode) |
void |
CreateWindowDesc.setInsertFilter(ExprNode insertFilter)
Sets the filter expression to use to apply
|
void |
OnTriggerMergeMatched.setOptionalMatchCond(ExprNode optionalMatchCond) |
void |
OnTriggerMergeEntry.setOptionalMatchCond(ExprNode optionalMatchCond) |
void |
UpdateDesc.setOptionalWhereClause(ExprNode optionalWhereClause)
Sets the where-clause if defined.
|
void |
OnTriggerMergeAction.setOptionalWhereClause(ExprNode optionalWhereClause) |
void |
SelectClauseExprCompiledSpec.setSelectExpression(ExprNode selectExpression)
Sets the select expression to use.
|
void |
OutputLimitSpec.setWhenExpressionNode(ExprNode whenExpressionNode)
Sets a new when-keyword trigger expression.
|
static Expression |
StatementSpecMapper.unmap(ExprNode expression)
Unmap expresission.
|
Modifier and Type | Method and Description |
---|---|
void |
ForClauseItemSpec.setExpressions(List<ExprNode> expressions) |
void |
MatchRecognizeSpec.setPartitionByExpressions(List<ExprNode> partitionByExpressions)
Returns partition expressions.
|
void |
StatementSpecRaw.setSqlParameters(Map<Integer,List<ExprNode>> sqlParameters) |
Constructor and Description |
---|
ContextDetailCategoryItem(ExprNode expression,
String name) |
ContextDetailInitiatedTerminated(ContextDetailCondition start,
ContextDetailCondition end,
boolean overlapping,
ExprNode[] distinctExpressions) |
CreateTableColumn(String columnName,
ExprNode optExpression,
String optTypeName,
Boolean optTypeIsArray,
Boolean optTypeIsPrimitiveArray,
List<AnnotationDesc> annotations,
Boolean primaryKey) |
CreateVariableDesc(String variableType,
String variableName,
ExprNode assignment,
boolean constant,
boolean array,
boolean arrayOfPrimitive)
Ctor.
|
CreateWindowDesc(String windowName,
List<ViewSpec> viewSpecs,
StreamSpecOptions streamSpecOptions,
boolean insert,
ExprNode insertFilter,
List<ColumnDesc> columns,
String asEventTypeName)
Ctor.
|
ExpressionDeclItem(String name,
List<String> parametersNames,
ExprNode inner,
boolean alias) |
GroupByClauseElementExpr(ExprNode expr) |
GroupByClauseExpressions(ExprNode[] groupByNodes) |
GroupByClauseExpressions(ExprNode[] groupByNodes,
int[][] groupByRollupLevels,
ExprNode[][] selectClauseCopy,
ExprNode[] optHavingNodeCopy,
ExprNode[][] optOrderByPerLevel) |
GroupByClauseExpressions(ExprNode[] groupByNodes,
int[][] groupByRollupLevels,
ExprNode[][] selectClauseCopy,
ExprNode[] optHavingNodeCopy,
ExprNode[][] optOrderByPerLevel) |
GroupByClauseExpressions(ExprNode[] groupByNodes,
int[][] groupByRollupLevels,
ExprNode[][] selectClauseCopy,
ExprNode[] optHavingNodeCopy,
ExprNode[][] optOrderByPerLevel) |
GroupByClauseExpressions(ExprNode[] groupByNodes,
int[][] groupByRollupLevels,
ExprNode[][] selectClauseCopy,
ExprNode[] optHavingNodeCopy,
ExprNode[][] optOrderByPerLevel) |
MatchRecognizeDefineItem(String identifier,
ExprNode expression)
Ctor.
|
MatchRecognizeMeasureItem(ExprNode expr,
String name)
Ctor.
|
NewItem(String name,
ExprNode optExpression) |
OnTriggerMergeAction(ExprNode optionalWhereClause) |
OnTriggerMergeActionDelete(ExprNode optionalMatchCond) |
OnTriggerMergeActionInsert(ExprNode optionalWhereClause,
String optionalStreamName,
List<String> columns,
List<SelectClauseElementRaw> selectClause) |
OnTriggerMergeActionUpdate(ExprNode optionalMatchCond,
List<OnTriggerSetAssignment> assignments) |
OnTriggerMergeEntry(ExprNode optionalMatchCond) |
OnTriggerMergeMatched(boolean matchedUnmatched,
ExprNode optionalMatchCond,
List<OnTriggerMergeAction> actions) |
OnTriggerSetAssignment(ExprNode expression)
Ctor.
|
OnTriggerSplitStream(InsertIntoDesc insertInto,
SelectClauseSpecRaw selectClause,
OnTriggerSplitStreamFromClause fromClause,
ExprNode whereClause)
Ctor.
|
OrderByItem(ExprNode exprNode,
boolean ascending)
Ctor.
|
OutputLimitSpec(Double rate,
String variableForRate,
OutputLimitRateType rateType,
OutputLimitLimitType displayLimit,
ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
List<ExprNode> crontabAtSchedule,
ExprTimePeriod timePeriodExpr,
ExprTimePeriod afterTimePeriodExpr,
Integer afterNumberOfEvents,
boolean andAfterTerminate,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateSetExpressions) |
PropertyEvalAtom(ExprNode splitterExpression,
String optionalResultEventType,
String optionalAsName,
SelectClauseSpecRaw optionalSelectClause,
ExprNode optionalWhereClause)
Ctor.
|
SelectClauseExprCompiledSpec(ExprNode selectExpression,
String assignedName,
String providedName,
boolean isEvents)
Ctor.
|
SelectClauseExprRawSpec(ExprNode selectExpression,
String optionalAsName,
boolean isEvents)
Ctor.
|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
Set<String> variableReferences,
RowLimitSpec rowLimitSpec,
String[] eventTypeReferences,
Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
Map<Integer,List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
UpdateDesc(String optionalStreamName,
List<OnTriggerSetAssignment> assignments,
ExprNode optionalWhereClause)
Ctor.
|
Constructor and Description |
---|
ContextDetailConditionCrontab(List<ExprNode> crontab,
boolean immediate) |
CreateIndexItem(List<ExprNode> expressions,
String type,
List<ExprNode> parameters) |
CreateIndexItem(List<ExprNode> expressions,
String type,
List<ExprNode> parameters) |
FilterSpecRaw(String eventTypeName,
List<ExprNode> filterExpressions,
PropertyEvalSpec optionalPropertyEvalSpec)
Ctor.
|
ForClauseItemSpec(String keyword,
List<ExprNode> expressions) |
GroupByClauseElementCombinedExpr(List<ExprNode> expressions) |
MethodStreamSpec(String optionalStreamName,
ViewSpec[] viewSpecs,
String ident,
String className,
String methodName,
List<ExprNode> expressions,
String eventTypeName)
Ctor.
|
NamedWindowConsumerStreamSpec(String windowName,
String optionalAsName,
ViewSpec[] viewSpecs,
List<ExprNode> filterExpressions,
StreamSpecOptions streamSpecOptions,
PropertyEvaluator optPropertyEvaluator)
Ctor.
|
ObjectSpec(String namespace,
String objectName,
List<ExprNode> objectParameters)
Constructor.
|
OutputLimitSpec(Double rate,
String variableForRate,
OutputLimitRateType rateType,
OutputLimitLimitType displayLimit,
ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> thenExpressions,
List<ExprNode> crontabAtSchedule,
ExprTimePeriod timePeriodExpr,
ExprTimePeriod afterTimePeriodExpr,
Integer afterNumberOfEvents,
boolean andAfterTerminate,
ExprNode andAfterTerminateExpr,
List<OnTriggerSetAssignment> andAfterTerminateSetExpressions) |
PatternGuardSpec(String namespace,
String objectName,
List<ExprNode> objectParameters)
Constructor.
|
PatternObserverSpec(String namespace,
String objectName,
List<ExprNode> objectParameters)
Constructor.
|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
Set<String> variableReferences,
RowLimitSpec rowLimitSpec,
String[] eventTypeReferences,
Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
Map<Integer,List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
TableQueryStreamSpec(String optionalStreamName,
ViewSpec[] viewSpecs,
StreamSpecOptions streamSpecOptions,
String tableName,
List<ExprNode> filterExpressions) |
ViewSpec(String namespace,
String objectName,
List<ExprNode> viewParameters)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static List<ExprNode> |
StatementSpecRawAnalyzer.collectExpressionsShallow(StatementSpecRaw raw) |
Constructor and Description |
---|
SubselectAggregatorViewFilteredGrouped(AggregationService aggregationService,
ExprEvaluator optionalFilterExpr,
ExprEvaluatorContext exprEvaluatorContext,
ExprEvaluator[] groupKeys,
ExprNode filterExprNode) |
SubselectAggregatorViewFilteredUngrouped(AggregationService aggregationService,
ExprEvaluator optionalFilterExpr,
ExprEvaluatorContext exprEvaluatorContext,
ExprEvaluator[] groupKeys,
ExprNode filterExprNode) |
Constructor and Description |
---|
TableOnMergeMatch(ExprNode optionalCond,
List<TableOnMergeAction> actions,
EngineImportService engineImportService,
String statementName) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
TableColumnMethodPair.getAggregationNode() |
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 |
---|
TableColumnMethodPair(ExprEvaluator evaluator,
int targetIndex,
ExprNode aggregationNode) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExprTableExprEvaluatorBase.exprNode |
Modifier and Type | Method and Description |
---|---|
static ExprTableExprEvaluatorBase |
ExprTableEvalStrategyFactory.getTableAccessEvalStrategy(ExprNode exprNode,
String tableName,
Integer streamNum,
TableMetadataColumnAggregation agg) |
Constructor and Description |
---|
ExprTableExprEvaluatorAccess(ExprNode exprNode,
String tableName,
String subpropName,
int streamNum,
Class returnType,
AggregationAccessorSlotPair accessAccessorSlotPair,
EventType eventTypeColl) |
ExprTableExprEvaluatorBase(ExprNode exprNode,
String tableName,
String subpropName,
int streamNum,
Class returnType) |
ExprTableExprEvaluatorMethod(ExprNode exprNode,
String tableName,
String subpropName,
int streamNum,
Class returnType,
int methodNum) |
Modifier and Type | Method and Description |
---|---|
static void |
EPLValidationUtil.validateParametersTypePredefined(ExprNode[] expressions,
String invocableName,
String invocableCategory,
EPLExpressionParamType type) |
static void |
EPLValidationUtil.validateParameterType(String invocableName,
String invocableCategory,
boolean isFunction,
EPLExpressionParamType expectedTypeEnum,
Class[] expectedTypeClasses,
Class providedType,
int parameterNum,
ExprNode parameterExpression) |
Constructor and Description |
---|
FilterExprView(ExprNode exprNode,
ExprEvaluator exprEvaluator,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
OutputConditionExpressionFactory(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> assignments,
StatementContext statementContext,
ExprNode andWhenTerminatedExpr,
List<OnTriggerSetAssignment> afterTerminateAssignments,
boolean isStartConditionOnCreation) |
OutputConditionPolledExpressionFactory(ExprNode whenExpressionNode,
List<OnTriggerSetAssignment> assignments,
StatementContext statementContext)
Ctor.
|
Constructor and Description |
---|
OutputConditionCrontabFactory(List<ExprNode> scheduleSpecExpressionList,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionPolledCrontabFactory(List<ExprNode> scheduleSpecExpressionList,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualDWViewFactoryImpl.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters) |
Modifier and Type | Method and Description |
---|---|
static InstanceManufacturerFactory |
InstanceManufacturerFactoryFactory.getManufacturer(Class targetClass,
EngineImportService engineImportService,
ExprNode[] childNodes) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExprNodeAdapterBase.exprNode |
Modifier and Type | Method and Description |
---|---|
ExprNode |
FilterSpecParamExprNode.getExprNode()
Returns the expression node of the boolean expression this filter parameter represents.
|
ExprNode |
ExprNodeAdapterBase.getExprNode() |
ExprNode[] |
FilterSpecCompilerAdvIndexDesc.getIndexExpressions() |
ExprNode[] |
FilterSpecCompilerAdvIndexDesc.getKeyExpressions() |
ExprNode |
FilterParamExprMap.removeEntry(FilterSpecParam param)
Removes a filter parameter and it's associated expression node
|
static ExprNode |
FilterSpecCompilerMakeParamUtil.rewriteOrToInIfApplicable(ExprNode constituent) |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
FilterParamExprMap.getUnassignedExpressions()
Returns all expression nodes for which no filter parameter exists.
|
static List<ExprNode> |
FilterSpecCompiler.validateAllowSubquery(ExprNodeOrigin exprNodeOrigin,
List<ExprNode> exprNodes,
StreamTypeService streamTypeService,
StatementContext statementContext,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes)
Validates expression nodes and returns a list of validated nodes.
|
Modifier and Type | Method and Description |
---|---|
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) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableSingle(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
StatementContext statementContext,
int agentInstanceId) |
protected static FilterSpecParam |
FilterSpecCompilerMakeParamUtil.makeFilterParam(ExprNode constituent,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
String statementName)
For a given expression determine if this is optimizable and create the filter parameter
representing the expression, or null if not optimizable.
|
void |
FilterParamExprMap.put(ExprNode exprNode,
FilterSpecParam param)
Add a node and filter param.
|
void |
FilterParamExprMap.removeNode(ExprNode node) |
static ExprNode |
FilterSpecCompilerMakeParamUtil.rewriteOrToInIfApplicable(ExprNode constituent) |
Modifier and Type | Method and Description |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.build(List<ExprNode> validatedNodes,
EventType eventType,
String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
StatementContext stmtContext,
Collection<Integer> assignedTypeNumberStack) |
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) |
static FilterSpecCompiled |
FilterSpecCompiler.makeFilterSpec(EventType eventType,
String eventTypeName,
List<ExprNode> filterExpessions,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
StatementContext statementContext,
Collection<Integer> assignedTypeNumberStack)
Factory method for compiling filter expressions into a filter specification
for use with filter service.
|
protected static List<FilterSpecParam>[] |
FilterSpecCompilerPlanner.planFilterParameters(List<ExprNode> validatedNodes,
FilterSpecCompilerArgs args) |
static List<ExprNode> |
FilterSpecCompiler.validateAllowSubquery(ExprNodeOrigin exprNodeOrigin,
List<ExprNode> exprNodes,
StreamTypeService streamTypeService,
StatementContext statementContext,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes)
Validates expression nodes and returns a list of validated nodes.
|
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) |
FilterSpecCompilerAdvIndexDesc(ExprNode[] indexExpressions,
ExprNode[] keyExpressions,
AdvancedIndexConfigContextPartition indexSpec,
String indexType,
String indexName) |
FilterSpecCompilerAdvIndexDesc(ExprNode[] indexExpressions,
ExprNode[] keyExpressions,
AdvancedIndexConfigContextPartition indexSpec,
String indexType,
String indexName) |
FilterSpecParamExprNode(FilterSpecLookupable lookupable,
FilterOperator filterOperator,
ExprNode exprNode,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
VariableService variableService,
TableService tableService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
ConfigurationInformation configurationInformation,
boolean hasSubquery,
boolean hasTableAccess) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qAggAccessEnterLeave(boolean enter,
int index,
AggregationState state,
ExprNode aggExpr) |
void |
Instrumentation.qAggAccessEnterLeave(boolean enter,
int index,
AggregationState state,
ExprNode aggExpr) |
void |
InstrumentationDefault.qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
ExprNode aggExpr) |
void |
Instrumentation.qAggNoAccessEnterLeave(boolean enter,
int index,
AggregationMethod aggregationMethod,
ExprNode aggExpr) |
void |
InstrumentationDefault.qExprAnd(ExprNode exprNode) |
void |
Instrumentation.qExprAnd(ExprNode exprNode) |
void |
InstrumentationDefault.qExprBitwise(ExprNode exprNode,
BitWiseOpEnum bitWiseOpEnum) |
void |
Instrumentation.qExprBitwise(ExprNode exprNode,
BitWiseOpEnum bitWiseOpEnum) |
void |
InstrumentationDefault.qExprBool(ExprNode exprNode,
EventBean[] eventsPerStream) |
void |
Instrumentation.qExprBool(ExprNode exprNode,
EventBean[] eventsPerStream) |
void |
InstrumentationDefault.qExprEquals(ExprNode exprNode) |
void |
Instrumentation.qExprEquals(ExprNode exprNode) |
void |
InstrumentationDefault.qExprLike(ExprNode exprNode) |
void |
Instrumentation.qExprLike(ExprNode exprNode) |
void |
InstrumentationDefault.qExprTableSubpropAccessor(ExprNode exprNode,
String tableName,
String subpropName,
ExprAggregateNode aggregationExpression) |
void |
Instrumentation.qExprTableSubpropAccessor(ExprNode exprNode,
String tableName,
String subpropName,
ExprAggregateNode aggregationExpression) |
void |
InstrumentationDefault.qExprTableSubproperty(ExprNode exprNode,
String tableName,
String subpropName) |
void |
Instrumentation.qExprTableSubproperty(ExprNode exprNode,
String tableName,
String subpropName) |
void |
InstrumentationDefault.qExprTableTop(ExprNode exprNode,
String tableName) |
void |
Instrumentation.qExprTableTop(ExprNode exprNode,
String tableName) |
void |
InstrumentationDefault.qExprValue(ExprNode exprNode,
EventBean[] eventsPerStream) |
void |
Instrumentation.qExprValue(ExprNode exprNode,
EventBean[] eventsPerStream) |
void |
InstrumentationDefault.qRegExPartition(ExprNode[] partitionExpressionNodes) |
void |
Instrumentation.qRegExPartition(ExprNode[] partitionExpressionNodes) |
void |
InstrumentationDefault.qRegIntervalValue(ExprNode exprNode) |
void |
Instrumentation.qRegIntervalValue(ExprNode exprNode) |
void |
InstrumentationDefault.qResultSetProcessComputeGroupKeys(boolean enter,
ExprNode[] groupKeyNodeExpressions,
EventBean[] eventsPerStream) |
void |
Instrumentation.qResultSetProcessComputeGroupKeys(boolean enter,
ExprNode[] groupKeyNodeExpressions,
EventBean[] eventsPerStream) |
void |
InstrumentationDefault.qSubselectAggregation(ExprNode optionalFilterExprNode) |
void |
Instrumentation.qSubselectAggregation(ExprNode optionalFilterExprNode) |
void |
InstrumentationDefault.qWhereClauseFilter(ExprNode exprNode,
EventBean[] newData,
EventBean[] oldData) |
void |
Instrumentation.qWhereClauseFilter(ExprNode exprNode,
EventBean[] newData,
EventBean[] oldData) |
Modifier and Type | Field and Description |
---|---|
protected List<ExprNode> |
EvalEveryDistinctFactoryNode.distinctExpressions |
protected List<ExprNode> |
EvalEveryDistinctFactoryNode.expressions |
Modifier and Type | Method and Description |
---|---|
ExprNode |
EvalMatchUntilFactoryNode.getLowerBounds() |
ExprNode |
EvalMatchUntilFactoryNode.getSingleBound() |
ExprNode |
EvalMatchUntilFactoryNode.getUpperBounds() |
Modifier and Type | Method and Description |
---|---|
List<ExprNode> |
EvalEveryDistinctFactoryNode.getDistinctExpressions()
Returns distinct expressions.
|
List<ExprNode> |
EvalEveryDistinctFactoryNode.getExpressions()
Returns all expressions.
|
List<ExprNode> |
EvalFollowedByFactoryNode.getOptionalMaxExpressions() |
Modifier and Type | Method and Description |
---|---|
static Object |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
ExprNode parameter,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext) |
EvalFactoryNode |
PatternNodeFactoryImpl.makeMatchUntilNode(ExprNode lowerBounds,
ExprNode upperBounds,
ExprNode singleBounds) |
EvalFactoryNode |
PatternNodeFactory.makeMatchUntilNode(ExprNode lowerBounds,
ExprNode upperBounds,
ExprNode singleBounds) |
void |
EvalEveryDistinctFactoryNode.setDistinctExpressions(List<ExprNode> distinctExpressions,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ExprNode expiryTimeExp,
EngineImportService engineImportService,
String statementName) |
void |
EvalMatchUntilFactoryNode.setLowerBounds(ExprNode lowerBounds) |
void |
EvalMatchUntilFactoryNode.setSingleBound(ExprNode singleBound) |
void |
EvalMatchUntilFactoryNode.setUpperBounds(ExprNode upperBounds) |
Modifier and Type | Method and Description |
---|---|
static List<Object> |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
EvalFactoryNode |
PatternNodeFactoryImpl.makeEveryDistinctNode(List<ExprNode> expressions) |
EvalFactoryNode |
PatternNodeFactory.makeEveryDistinctNode(List<ExprNode> expressions) |
EvalFactoryNode |
PatternNodeFactoryImpl.makeFollowedByNode(List<ExprNode> maxExpressions,
boolean hasEngineWideMax) |
EvalFactoryNode |
PatternNodeFactory.makeFollowedByNode(List<ExprNode> maxExpressions,
boolean hasEngineWideMax) |
void |
EvalEveryDistinctFactoryNode.setDistinctExpressions(List<ExprNode> distinctExpressions,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ExprNode expiryTimeExp,
EngineImportService engineImportService,
String statementName) |
void |
EvalFollowedByFactoryNode.setOptionalMaxExpressions(List<ExprNode> optionalMaxExpressions) |
Constructor and Description |
---|
EvalMatchUntilFactoryNode(ExprNode lowerBounds,
ExprNode upperBounds,
ExprNode singleBound) |
Constructor and Description |
---|
EvalEveryDistinctFactoryNode(List<ExprNode> expressions)
Ctor.
|
EvalFollowedByFactoryNode(List<ExprNode> optionalMaxExpressions,
boolean hasEngineWidePatternCount) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExpressionGuardFactory.expression |
protected ExprNode |
TimerWithinOrMaxCountGuardFactory.numCountToExpr
Number of count-to max.
|
protected ExprNode |
TimerWithinOrMaxCountGuardFactory.timeExpr
Number of milliseconds.
|
protected ExprNode |
TimerWithinGuardFactory.timeExpr
Number of milliseconds.
|
Modifier and Type | Method and Description |
---|---|
void |
TimerWithinOrMaxCountGuardFactory.setGuardParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor) |
void |
TimerWithinGuardFactory.setGuardParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor) |
void |
GuardFactory.setGuardParameters(List<ExprNode> guardParameters,
MatchedEventConvertor convertor)
Sets the guard object parameters.
|
void |
ExpressionGuardFactory.setGuardParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
TimerIntervalObserverFactory.parameter
Parameters.
|
Modifier and Type | Field and Description |
---|---|
protected List<ExprNode> |
TimerAtObserverFactory.parameters
Parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
TimerScheduleObserverFactory.setObserverParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
TimerIntervalObserverFactory.setObserverParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
TimerAtObserverFactory.setObserverParameters(List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
ObserverFactory.setObserverParameters(List<ExprNode> observerParameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext)
Sets the observer object parameters.
|
static void |
ObserverParameterUtil.validateNoNamedParameters(String name,
List<ExprNode> parameter) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
PlugInAggregationMultiFunctionValidationContext.getAllParameterExpressions()
Returns positional and non-positional parameters.
|
ExprNode[] |
PlugInAggregationMultiFunctionAgentContext.getChildNodes() |
ExprNode |
PlugInAggregationMultiFunctionAgentContext.getOptionalFilterExpression() |
ExprNode[] |
PlugInAggregationMultiFunctionValidationContext.getParameterExpressions()
Returns positional parameters expressions to this aggregation function.
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,List<ExprNode>> |
PlugInAggregationMultiFunctionValidationContext.getNamedParameters()
Gets the named parameters as a list
|
Modifier and Type | Field and Description |
---|---|
protected HashMap<String,Pair<ExprNode,ExprEvaluator>> |
EventRowRegexNFAViewFactory.variableDefinitions |
Modifier and Type | Method and Description |
---|---|
ExprNode |
RowRegexExprRepeatDesc.getLower() |
ExprNode[] |
RegexPartitionStateRepoGroupMeta.getPartitionExpressionNodes() |
ExprNode |
RowRegexExprRepeatDesc.getSingle() |
ExprNode |
RowRegexExprRepeatDesc.getUpper() |
Modifier and Type | Method and Description |
---|---|
protected static RegexNFAStrandResult |
EventRowRegexHelper.recursiveBuildStartStates(RowRegexExprNode parent,
Map<String,Pair<ExprNode,ExprEvaluator>> variableDefinitions,
Map<String,Pair<Integer,Boolean>> variableStreams,
boolean[] exprRequiresMultimatchState)
Build a list of start states from the parent node.
|
void |
EventRowRegexNFAViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters) |
Constructor and Description |
---|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
RowRegexExprRepeatDesc(ExprNode lower,
ExprNode upper,
ExprNode single) |
Constructor and Description |
---|
RegexNFAStateFilter(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
Pair<ExprNode,ExprEvaluator> expression,
boolean exprRequiresMultimatchState)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
MinMaxTypeEnum.ComputerBigDecCoerce.codegen(boolean max,
CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode[] nodes,
SimpleNumberBigDecimalCoercer[] convertors) |
static CodegenExpression |
MinMaxTypeEnum.ComputerBigIntCoerce.codegen(boolean max,
CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode[] nodes,
SimpleNumberBigIntegerCoercer[] convertors) |
static CodegenExpression |
MinMaxTypeEnum.MinComputerDoubleCoerce.codegen(CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode[] nodes,
Class returnType) |
static CodegenExpression |
MinMaxTypeEnum.MaxComputerDoubleCoerce.codegen(CodegenContext context,
CodegenParamSetExprPremade params,
ExprNode[] nodes,
Class returnType) |
Modifier and Type | Method and Description |
---|---|
static Pair<ExprNode,String> |
StatementSelectionUtil.compileValidateStatementFilterExpr(EPServiceProviderSPI engine,
String filterExpression) |
Modifier and Type | Method and Description |
---|---|
static boolean |
StatementSelectionUtil.evaluateStatement(ExprNode expression,
EPStatement stmt) |
static Comparator<Object> |
CollectionUtil.getComparator(ExprNode[] sortCriteria,
ExprEvaluator[] sortCriteriaEvaluators,
boolean isSortUsingCollator,
boolean[] isDescendingValues) |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ViewFactorySupport.validate(String viewName,
EventType eventType,
StatementContext statementContext,
List<ExprNode> expressions,
boolean allowConstantResult)
Validate the view parameter expressions and return the validated expression for later execution.
|
static ExprNode[] |
ViewFactorySupport.validate(String viewName,
StatementContext statementContext,
List<ExprNode> expressions) |
static ExprNode |
ViewFactorySupport.validateExpr(String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
Modifier and Type | Method and Description |
---|---|
static void |
ViewFactorySupport.assertReturnsNonConstant(String viewName,
ExprNode expression,
int index)
Assert and throws an exception if the expression passed returns a non-constant value.
|
static Object |
ViewFactorySupport.evaluateAssertNoProperties(String viewName,
ExprNode expression,
int index,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
ViewFactorySupport.validateAndEvaluate(String viewName,
StatementContext statementContext,
ExprNode expression)
Validate the view parameter expression and evaluate the expression returning the result object.
|
static Object |
ViewFactorySupport.validateAndEvaluateExpr(String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
static ExprTimePeriodEvalDeltaConstFactory |
ViewFactoryTimePeriodHelper.validateAndEvaluateTimeDeltaFactory(String viewName,
StatementContext statementContext,
ExprNode expression,
String expectedMessage,
int expressionNumber) |
static ExprNode |
ViewFactorySupport.validateExpr(String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
static void |
ViewFactorySupport.validateNoProperties(String viewName,
ExprNode expression,
int index) |
static ExprEvaluator |
ViewFactorySupport.validateSizeParam(String viewName,
StatementContext statementContext,
ExprNode sizeNode,
int expressionNumber) |
Modifier and Type | Method and Description |
---|---|
void |
ViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters)
Indicates user EPL query view parameters to the view factory.
|
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.
|
static ExprNode[] |
ViewFactorySupport.validate(String viewName,
EventType eventType,
StatementContext statementContext,
List<ExprNode> expressions,
boolean allowConstantResult)
Validate the view parameter expressions and return the validated expression for later execution.
|
static ExprNode[] |
ViewFactorySupport.validate(String viewName,
StatementContext statementContext,
List<ExprNode> expressions) |
static void |
ViewFactorySupport.validateNoParameters(String viewName,
List<ExprNode> expressionParameters) |
static ExprEvaluator |
ViewFactorySupport.validateSizeSingleParam(String viewName,
ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
SortWindowViewFactory.sortCriteriaExpressions
The sort-by expressions.
|
protected ExprNode[] |
RankWindowViewFactory.sortCriteriaExpressions
The sort-by expressions.
|
protected ExprNode |
TimeToLiveViewFactory.timestampExpression
The timestamp expression.
|
protected ExprNode |
TimeOrderViewFactory.timestampExpression
The timestamp expression.
|
protected ExprNode[] |
RankWindowViewFactory.uniqueCriteriaExpressions
The unique-by expressions.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
SortWindowViewFactory.getSortCriteriaExpressions() |
protected ExprNode[] |
SortWindowView.getSortCriteriaExpressions()
Returns the field names supplying the values to sort by.
|
ExprNode[] |
RankWindowViewFactory.getSortCriteriaExpressions() |
ExprNode |
TimeToLiveViewFactory.getTimestampExpression() |
ExprNode |
TimeOrderView.getTimestampExpression()
Returns the timestamp property name.
|
ExprNode[] |
RankWindowViewFactory.getUniqueCriteriaExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
TimeToLiveViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
TimeOrderViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
SortWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParams) |
void |
RankWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParams) |
Constructor and Description |
---|
TimeOrderView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ViewFactory viewFactory,
ExprNode timestampExpr,
ExprEvaluator timestampEvaluator,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
IStreamSortRankRandomAccess optionalSortedRandomAccess) |
Modifier and Type | Method and Description |
---|---|
void |
UnionViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters) |
void |
PriorEventViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
NoopViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters) |
void |
IntersectViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> viewParameters) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
RegressionLinestViewFactory.expressionX |
protected ExprNode |
CorrelationViewFactory.expressionX |
protected ExprNode |
RegressionLinestViewFactory.expressionY |
protected ExprNode |
CorrelationViewFactory.expressionY |
protected ExprNode |
UnivariateStatisticsViewFactory.fieldExpression
Property name of data field.
|
protected ExprNode |
WeightedAverageViewFactory.fieldNameWeight |
protected ExprNode |
WeightedAverageViewFactory.fieldNameX |
Modifier and Type | Method and Description |
---|---|
ExprNode |
BaseBivariateStatisticsView.getExpressionX()
Returns the expression supplying X data points.
|
ExprNode |
BaseBivariateStatisticsView.getExpressionY()
Returns the expression supplying Y data points.
|
ExprNode |
UnivariateStatisticsView.getFieldExpression()
Returns field name of the field to report statistics on.
|
ExprNode |
WeightedAverageView.getFieldNameWeight()
Returns the expression supplying the weight values.
|
ExprNode |
WeightedAverageView.getFieldNameX()
Returns the expression supplying the X values.
|
Modifier and Type | Method and Description |
---|---|
static StatViewAdditionalProps |
StatViewAdditionalProps.make(ExprNode[] validated,
int startIndex,
EventType parentEventType,
EngineImportService engineImportService,
String statementName) |
void |
UnivariateStatisticsViewFactory.setFieldExpression(ExprNode fieldExpression) |
void |
WeightedAverageViewFactory.setFieldNameWeight(ExprNode fieldNameWeight) |
void |
WeightedAverageViewFactory.setFieldNameX(ExprNode fieldNameX) |
Modifier and Type | Method and Description |
---|---|
void |
WeightedAverageViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
UnivariateStatisticsViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
RegressionLinestViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
CorrelationViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
Constructor and Description |
---|
BaseBivariateStatisticsView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode expressionX,
ExprEvaluator expressionXEval,
ExprNode expressionY,
ExprEvaluator expressionYEval,
EventType eventType,
StatViewAdditionalProps additionalProps)
Constructor requires the name of the two fields to use in the parent view to compute the statistics.
|
CorrelationView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xExpression,
ExprEvaluator xExpressionEval,
ExprNode yExpression,
ExprEvaluator yExpressionEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprEvaluator xEval,
ExprNode yFieldName,
ExprEvaluator yEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
UniqueByPropertyViewFactory.criteriaExpressions
Property name to evaluate unique values.
|
protected ExprNode[] |
GroupByViewFactory.criteriaExpressions
List of criteria expressions.
|
protected ExprNode[] |
FirstUniqueByPropertyViewFactory.criteriaExpressions
Property name to evaluate unique values.
|
Modifier and Type | Field and Description |
---|---|
protected List<ExprNode> |
UniqueByPropertyViewFactory.viewParameters
View parameters.
|
protected List<ExprNode> |
GroupByViewFactory.viewParameters
View parameters.
|
protected List<ExprNode> |
FirstUniqueByPropertyViewFactory.viewParameters
View parameters.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
UniqueByPropertyViewFactory.getCriteriaExpressions() |
ExprNode[] |
UniqueByPropertyView.getCriteriaExpressions()
Returns the name of the field supplying the unique value to keep the most recent record for.
|
ExprNode[] |
MergeViewFactory.getCriteriaExpressions() |
ExprNode[] |
GroupByViewReclaimAged.getCriteriaExpressions()
Returns the field name that provides the key valie by which to group by.
|
ExprNode[] |
GroupByViewImpl.getCriteriaExpressions()
Returns the field name that provides the key valie by which to group by.
|
ExprNode[] |
GroupByViewFactoryMarker.getCriteriaExpressions() |
ExprNode[] |
GroupByViewFactory.getCriteriaExpressions()
Returns the names of fields to group by
|
ExprNode[] |
GroupByView.getCriteriaExpressions() |
ExprNode[] |
FirstUniqueByPropertyViewFactory.getCriteriaExpressions() |
ExprNode[] |
MergeViewMarker.getGroupFieldNames() |
ExprNode[] |
MergeView.getGroupFieldNames()
Returns the field name that contains the values to group by.
|
ExprNode[] |
FirstUniqueByPropertyView.getUniqueCriteria()
Returns the expressions supplying the unique value to keep the most recent record for.
|
Modifier and Type | Method and Description |
---|---|
void |
UniqueByPropertyViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
SizeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
MergeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
LastElementViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
GroupByViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
FirstUniqueByPropertyViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
FirstElementViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
Constructor and Description |
---|
GroupByViewImpl(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators)
Constructor.
|
GroupByViewReclaimAged(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators,
double reclaimMaxAgeSeconds,
double reclaimFrequencySeconds)
Constructor.
|
MergeView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] groupCriteria,
EventType resultEventType,
boolean removable) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExpressionViewFactoryBase.expiryExpression |
protected ExprNode |
ExternallyTimedWindowViewFactory.timestampExpression
The timestamp property name.
|
protected ExprNode |
ExternallyTimedBatchViewFactory.timestampExpression
The timestamp property name.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExpressionViewFactoryBase.getExpiryExpression() |
ExprNode |
ExternallyTimedWindowView.getTimestampExpression()
Returns the field name to get timestamp values from.
|
ExprNode |
ExternallyTimedBatchView.getTimestampExpression()
Returns the field name to get timestamp values from.
|
Modifier and Type | Method and Description |
---|---|
void |
TimeWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
TimeLengthBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
TimeBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
TimeAccumViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
LengthWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
LengthBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
KeepAllViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
FirstTimeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
FirstLengthWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
ExternallyTimedWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
ExternallyTimedBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
ExpressionWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
void |
ExpressionBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
Constructor and Description |
---|
ExternallyTimedBatchView(ExternallyTimedBatchViewFactory factory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long optionalReferencePoint,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|
ExternallyTimedWindowView(ExternallyTimedWindowViewFactory externallyTimedWindowViewFactory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|