| 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.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) |
| Constructor and Description |
|---|
ContextControllerHashedGetterCRC32Serialized(String statementName,
List<ExprNode> nodes,
int granularity) |
ContextControllerHashedGetterHashMultiple(List<ExprNode> nodes,
int granularity) |
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,
ExprNode optionalWhereClause,
ExprNode[] assignments,
EventBeanWriter writer,
TypeWidener[] wideners,
InternalRoutePreprocessView outputView,
StatementAgentInstanceLock agentInstanceLock,
boolean hasSubselect)
Ctor.
|
InternalEventRouterEntry(int priority,
boolean drop,
ExprNode 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) |
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) |
| 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) |
| 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) |
| 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 |
|---|---|
static OrderByProcessorFactory |
OrderByProcessorFactoryFactory.getProcessor(List<SelectClauseExprCompiledSpec> selectionList,
ExprNode[] groupByNodes,
List<OrderByItem> orderByList,
RowLimitSpec rowLimitSpec,
VariableService variableService,
boolean isSortUsingCollator,
String optionalContextName)
Returns processor for order-by clauses.
|
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) |
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) |
OrderByProcessorFactoryImpl(List<OrderByItem> orderByList,
ExprNode[] groupByNodes,
boolean needsGroupByKeys,
boolean isSortUsingCollator)
Ctor.
|
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 |
|---|---|
CalendarOp |
CalendarOpFactory.getOp(DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
ExprEvaluator[] evaluators) |
| 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 ExprDotEvalDTMethodDesc |
ExprDotEvalDTFactory.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 |
IntervalOpImpl.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 |
IntervalOp.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
IntervalOp |
IntervalOpFactory.getOp(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputer |
IntervalComputerFactory.make(DatetimeMethodEnum method,
List<ExprNode> expressions,
TimeAbacus timeAbacus) |
| Constructor and Description |
|---|
IntervalOpImpl(DatetimeMethodEnum method,
String methodNameUse,
StreamTypeService streamTypeService,
List<ExprNode> expressions,
TimeZone timeZone,
TimeAbacus timeAbacus) |
| Constructor and Description |
|---|
ReformatOpBetweenConstantParams(List<ExprNode> parameters,
TimeZone timeZone) |
ReformatOpBetweenNonConstantParams(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 |
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 |
ExprDotEvalEnumMethodBase.init(Integer streamOfProviderIfApplicable,
EnumMethodEnum enumMethodEnum,
String enumMethodUsedName,
EPType typeInfo,
List<ExprNode> parameters,
ExprValidationContext validationContext) |
void |
ExprDotEvalEnumMethod.init(Integer streamOfProviderIfApplicable,
EnumMethodEnum lambda,
String lambdaUsedName,
EPType currentInputType,
List<ExprNode> parameters,
ExprValidationContext validationContext) |
| Constructor and Description |
|---|
ExprDotEvalParam(int parameterNum,
ExprNode body,
ExprEvaluator bodyEvaluator) |
ExprDotEvalParamExpr(int parameterNum,
ExprNode body,
ExprEvaluator bodyEvaluator) |
ExprDotEvalParamLambda(int parameterNum,
ExprNode body,
ExprEvaluator 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) |
static int |
ExprAggMultiFunctionUtil.validateStreamWildcardGetStreamNum(ExprNode node) |
| 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 |
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 |
ExprContextPropertyNode
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 |
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 |
ExprContextPropertyNode.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 |
ExprContextPropertyNode.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.getEvaluators(ExprNode[] exprNodes) |
static List<Pair<Integer,String>> |
ExprNodeUtility.getExpressionProperties(ExprNode exprNode,
boolean visitAggregateNodes)
Walk expression returning properties used.
|
static Class[] |
ExprNodeUtility.getExprResultTypes(ExprNode[] groupByNodes) |
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.getEvaluators(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 |
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 ExprDotEnumerationSource |
ExprDotNodeUtility.getEnumerationSource(ExprNode inputExpression,
StreamTypeService streamTypeService,
EventAdapterService eventAdapterService,
int statementId,
boolean hasEnumerationMethod,
boolean disablePropertyExpressionEventCollCache) |
void |
ExprDotNodeImpl.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
| 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 |
ExprCaseNode.CaseAnalysis.getOptionalCompareExprNode() |
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>> |
ExprCaseNode.CaseAnalysis.getWhenThenNodeList() |
| Modifier and Type | Method and Description |
|---|---|
void |
ExprPlugInSingleRowNode.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
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 |
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 |
|---|---|
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.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.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)
Sets the validate 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 |
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.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 ExprEvaluator |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprEvaluator |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprEvaluator |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprEvaluator |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprEvaluator |
EngineImportApplicationDotMethodBase.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprEvaluator |
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) |
JoinSetComposerPrototypeHistorical2StreamImpl(ExprNode optionalFilterNode,
EventType[] streamTypes,
ExprEvaluatorContext exprEvaluatorContext,
int polledViewNum,
int streamViewNum,
boolean outerJoin,
ExprNode outerJoinEqualsNode,
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> indexStrategies,
boolean allHistoricalNoSubordinate,
OuterJoinDesc[] outerJoinDescList,
boolean allowIndexInit) |
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) |
| 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) |
| 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 |
|---|---|
List<ExprNode> |
NamedWindowConsumerDesc.getFilterList() |
| 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 |
|---|
NamedWindowOnMergeMatch(ExprNode optionalCond,
List<NamedWindowOnMergeAction> actions) |
| Constructor and Description |
|---|
NamedWindowConsumerDesc(List<ExprNode> filterList,
PropertyEvaluator optPropertyEvaluator,
AgentInstanceContext agentInstanceContext) |
| 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) |
| 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 ExprEvaluator |
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 InstanceManufacturer |
InstanceManufacturerFactory.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,
EventBean[] events) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableServiceToUse,
EventBean[] events) |
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) |
ExprNodeAdapterBaseStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService) |
ExprNodeAdapterBaseVariables(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService) |
ExprNodeAdapterBaseWTableAccess(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
ExprNodeAdapterBase evalBase,
TableService tableService) |
ExprNodeAdapterMultiStream(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype) |
ExprNodeAdapterMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype) |
ExprNodeAdapterMultiStreamNoTLStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype) |
ExprNodeAdapterMultiStreamStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype) |
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) |
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) |
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 | 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,ExprNode> 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 |
|---|
RegexNFAStateFilter(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
ExprNode exprNode,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexNFAStateOneOptional(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprNode exprNode,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexNFAStateOneToMany(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprNode exprNode,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexNFAStateZeroToMany(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprNode exprNode,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
RowRegexExprRepeatDesc(ExprNode lower,
ExprNode upper,
ExprNode single) |
| 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) |
| 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 |
|---|---|
protected ExprNode[] |
SortWindowView.getSortCriteriaExpressions()
Returns the field names supplying the values to sort by.
|
ExprNode |
TimeToLiveViewFactory.getTimestampExpression() |
ExprNode |
TimeOrderView.getTimestampExpression()
Returns the timestamp property name.
|
| 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 |
|---|
RankWindowView(RankWindowViewFactory rankWindowViewFactory,
ExprNode[] uniqueCriteriaExpressions,
ExprEvaluator[] uniqueCriteriaEvaluators,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalRankedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
RankWindowView(RankWindowViewFactory rankWindowViewFactory,
ExprNode[] uniqueCriteriaExpressions,
ExprEvaluator[] uniqueCriteriaEvaluators,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalRankedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
SortWindowView(SortWindowViewFactory sortWindowViewFactory,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalSortedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
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
Expression X field.
|
protected ExprNode |
CorrelationViewFactory.expressionX
Property name of X field.
|
protected ExprNode |
RegressionLinestViewFactory.expressionY
Expression Y field.
|
protected ExprNode |
CorrelationViewFactory.expressionY
Property name of Y field.
|
protected ExprNode |
UnivariateStatisticsViewFactory.fieldExpression
Property name of data field.
|
protected ExprNode |
WeightedAverageViewFactory.fieldNameWeight
Expression of weight field.
|
protected ExprNode |
WeightedAverageViewFactory.fieldNameX
Expression of X field.
|
| 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) |
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,
ExprNode expressionY,
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,
ExprNode yExpression,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprNode yFieldName,
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[] |
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[] |
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.
|