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.access |
State multifunction aggregation methods
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
com.espertech.esper.epl.agg.service.common |
Aggregation services - common.
|
com.espertech.esper.epl.agg.service.groupby |
Aggregation services group-by regular
|
com.espertech.esper.epl.agg.service.table |
Aggregation services - table aggregation.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
com.espertech.esper.epl.core.engineimport |
Engine import handling
|
com.espertech.esper.epl.core.orderby |
Order-by and row-limit processors
|
com.espertech.esper.epl.core.poll |
Polled executions for use with method-invocation joins
|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.grouped |
Result set processor utility classes for general grouped-aggregation
|
com.espertech.esper.epl.core.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
com.espertech.esper.epl.core.select |
Select-clause processing.
|
com.espertech.esper.epl.core.select.eval |
Select expression evaluators.
|
com.espertech.esper.epl.datetime.calop |
Date-Time calendar operations.
|
com.espertech.esper.epl.datetime.eval |
Date-Time methods and related utility classes.
|
com.espertech.esper.epl.datetime.interval |
Interval algebra.
|
com.espertech.esper.epl.datetime.reformatop |
Date-Time re-formatting operations.
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
com.espertech.esper.epl.declexpr |
Declared expression handling.
|
com.espertech.esper.epl.enummethod.dot |
Enumeration method utility classes and input data sources.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.expression.baseagg |
Base aggregation expressions.
|
com.espertech.esper.epl.expression.core |
Core expression classes.
|
com.espertech.esper.epl.expression.dot |
Chained expression functionality.
|
com.espertech.esper.epl.expression.funcs |
Function expressions.
|
com.espertech.esper.epl.expression.methodagg |
Method-aggregation expressions.
|
com.espertech.esper.epl.expression.ops |
Operator expressions.
|
com.espertech.esper.epl.expression.prev |
'Previous'-group expressions.
|
com.espertech.esper.epl.expression.prior |
'Prior'-group expressions.
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.expression.table |
Table access and identifiers expressions.
|
com.espertech.esper.epl.expression.time |
Time-related expressions.
|
com.espertech.esper.epl.expression.visitor |
Expression visitors.
|
com.espertech.esper.epl.index.quadtree |
Quad-tree indexes
|
com.espertech.esper.epl.index.service |
Advanced index provisioning
|
com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
com.espertech.esper.epl.join.exec.base |
Inner join execution
|
com.espertech.esper.epl.join.hint |
Hints related to joins.
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.join.util |
Join-related utilities
|
com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
com.espertech.esper.epl.methodbase |
Dot-method validation for enumeration and date-time methods.
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
com.espertech.esper.epl.rettype |
EPL-internal expression return type.
|
com.espertech.esper.epl.script |
Script expression evaluation.
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.spec.util |
Statement spec utilities
|
com.espertech.esper.epl.subquery |
Subquery helper classes are found here.
|
com.espertech.esper.epl.table.merge |
Table on-merge handlers.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
com.espertech.esper.epl.util |
EPL utility classes.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
com.espertech.esper.epl.virtualdw |
Virtual data window.
|
com.espertech.esper.event.bean |
JavaBean and legacy Java underlying event classes are here.
|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
com.espertech.esper.pattern.guard |
Pattern guards that can define the lifetime of a pattern
|
com.espertech.esper.pattern.observer |
Pattern observer classes the observe timer events
|
com.espertech.esper.plugin |
APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in
this package.
|
com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
com.espertech.esper.type |
Internal primitive, enum and other type representations
|
com.espertech.esper.util |
Utility classes that center around Java type handling, printing, reflection, debugging
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.stat |
Views computing statistical values.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.window |
Window views are in this package
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
VirtualDataWindowEventConsumerAdd.getFilterExpressions()
Provides the filter expressions.
|
ExprNode[] |
VirtualDataWindowFactoryContext.getParameterExpressions()
Returns the expressions passed as parameters to the virtual data window.
|
ExprNode[] |
VirtualDataWindowContext.getParameterExpressions()
Returns the expressions passed as parameters to the virtual data window.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<ExprNode> |
VirtualDataWindowEventStartIndex.VDWCreateIndexField.getExpressions()
Returns index expressions
|
java.util.List<ExprNode> |
VirtualDataWindowEventStartIndex.VDWCreateIndexField.getParameters()
Returns index field parameters if any
|
Constructor and Description |
---|
VirtualDataWindowContext(AgentInstanceContext agentInstanceContext,
EventType eventType,
java.lang.Object[] parameters,
ExprNode[] parameterExpressions,
EventBeanFactory eventFactory,
VirtualDataWindowOutStream outputStream,
java.lang.String namedWindowName,
ViewFactoryContext viewFactoryContext,
java.io.Serializable customConfiguration)
Ctor.
|
VirtualDataWindowEventConsumerAdd(java.lang.String namedWindowName,
java.lang.Object consumerObject,
java.lang.String statementName,
int agentInstanceId,
ExprNode[] filterExpressions,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
VirtualDataWindowFactoryContext(EventType eventType,
java.lang.Object[] parameters,
ExprNode[] parameterExpressions,
EventBeanFactory eventFactory,
java.lang.String namedWindowName,
ViewFactoryContext viewFactoryContext,
java.io.Serializable customConfiguration)
Ctor.
|
Constructor and Description |
---|
VDWCreateIndexField(java.util.List<ExprNode> expressions,
java.lang.String type,
java.util.List<ExprNode> parameters)
Ctor.
|
VDWCreateIndexField(java.util.List<ExprNode> expressions,
java.lang.String type,
java.util.List<ExprNode> parameters)
Ctor.
|
Constructor and Description |
---|
ViewableActivatorNamedWindow(NamedWindowProcessor processor,
java.util.List<ExprNode> filterExpressions,
PropertyEvaluator optPropertyEvaluator,
EngineImportService engineImportService,
java.lang.String statementName) |
Constructor and Description |
---|
ContextControllerHashedGetterCRC32Serialized(java.lang.String statementName,
java.util.List<ExprNode> nodes,
int granularity,
EngineImportService engineImportService) |
ContextControllerHashedGetterHashMultiple(java.util.List<ExprNode> nodes,
int granularity,
EngineImportService engineImportService,
java.lang.String statementName) |
ContextControllerHashedGetterSingleRow(java.lang.String statementName,
java.lang.String functionName,
Pair<java.lang.Class,EngineImportSingleRowDesc> func,
java.util.List<ExprNode> parameters,
int granularity,
EngineImportService engineImportService,
EventType eventType,
EventAdapterService eventAdapterService,
int statementId,
TableService tableService,
java.lang.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(java.lang.String expression)
Compile expression.
|
ExprNode |
EPAdministratorImpl.compileExpression(java.lang.String expression) |
Constructor and Description |
---|
InternalEventRouterEntry(int priority,
boolean drop,
ExprEvaluator optionalWhereClause,
ExprNode[] assignments,
EventBeanWriter writer,
TypeWidener[] wideners,
InternalRoutePreprocessView outputView,
StatementAgentInstanceLock agentInstanceLock,
boolean hasSubselect)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
EPPreparedExecuteIUDSingleStreamExecUpdate.getOptionalWhereClause() |
ExprNode |
EPPreparedExecuteIUDSingleStreamExecDelete.getOptionalWhereClause() |
ExprNode |
EPStatementStartMethodOnTriggerItem.getWhereClause() |
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String errorMsg,
boolean allowTableConsumption) |
protected ExprNode |
EPStatementStartMethodOnTrigger.validateJoinNamedWindow(java.lang.String engineURI,
StatementContext statementContext,
ExprNodeOrigin exprNodeOrigin,
ExprNode deleteJoinExpr,
EventType namedWindowType,
java.lang.String namedWindowStreamName,
java.lang.String namedWindowName,
EventType filteredType,
java.lang.String filterStreamName,
java.lang.String filteredTypeName,
java.lang.String optionalTableName) |
Modifier and Type | Method and Description |
---|---|
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String errorMsg,
boolean allowTableConsumption) |
protected ExprNode |
EPStatementStartMethodOnTrigger.validateJoinNamedWindow(java.lang.String engineURI,
StatementContext statementContext,
ExprNodeOrigin exprNodeOrigin,
ExprNode deleteJoinExpr,
EventType namedWindowType,
java.lang.String namedWindowStreamName,
java.lang.String namedWindowName,
EventType filteredType,
java.lang.String filterStreamName,
java.lang.String filteredTypeName,
java.lang.String optionalTableName) |
protected static void |
EPStatementStartMethodHelperValidate.validateNoAggregations(ExprNode exprNode,
java.lang.String errorMsg) |
protected static void |
EPStatementStartMethodHelperValidate.validateSubqueryExcludeOuterStream(ExprNode matchCondition) |
Constructor and Description |
---|
EPPreparedExecuteIUDSingleStreamExecDelete(QueryGraph queryGraph,
ExprNode optionalWhereClause,
java.lang.annotation.Annotation[] annotations,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPPreparedExecuteIUDSingleStreamExecUpdate(QueryGraph queryGraph,
ExprNode optionalWhereClause,
java.lang.annotation.Annotation[] annotations,
EventBeanUpdateHelper updateHelper,
TableUpdateStrategy tableUpdateStrategy,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPStatementStartMethodOnTriggerItem(ExprNode whereClause,
boolean isNamedWindowInsert,
java.lang.String insertIntoTableNames,
ResultSetProcessorFactoryDesc factoryDesc,
PropertyEvaluator propertyEvaluator) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
EventBusSource.filter |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
AggregationStateSortedSpecForge.getCriteria() |
ExprNode[] |
AggregationStateMinMaxByEverSpecForge.getCriteria() |
Modifier and Type | Method and Description |
---|---|
static CodegenMethodNode |
AggregationStateSortedImpl.getComparableCodegen(java.lang.String methodName,
ExprNode[] criteria,
CodegenNamedMethods namedMethods,
CodegenClassScope classScope) |
Constructor and Description |
---|
AggregationStateMinMaxByEverSpecForge(int streamId,
ExprNode[] criteria,
boolean max,
java.util.Comparator<java.lang.Object> comparator,
java.lang.Object criteriaKeyBinding,
ExprForge optionalFilter) |
AggregationStateSortedSpecForge(int streamId,
ExprNode[] criteria,
java.util.Comparator<java.lang.Object> comparator,
java.lang.Object criteriaKeyBinding,
ExprForge optionalFilter,
boolean join) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
AggregationMethodFactoryAvedev.positionalParameters |
Modifier and Type | Method and Description |
---|---|
ExprNode |
AggregationStateSortedFactory.getAggregationExpression() |
ExprNode |
AggregationStatePluginFactory.getAggregationExpression() |
ExprNode |
AggregationStateMinMaxByEverFactory.getAggregationExpression() |
ExprNode |
AggregationStateLinearFactory.getAggregationExpression() |
ExprNode |
AggregationStateFactoryCountMinSketch.getAggregationExpression() |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
java.lang.Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
java.lang.Class childType,
ExprNode[] positionalParams) |
Constructor and Description |
---|
AggregationMethodFactoryAvedev(ExprAvedevNode parent,
java.lang.Class aggregatedValueType,
ExprNode[] positionalParameters) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
GroupByRollupPlanDesc.getExpressions() |
Modifier and Type | Method and Description |
---|---|
static GroupByClauseExpressions |
GroupByExpressionHelper.getGroupByRollupExpressions(java.util.List<GroupByClauseElement> groupByElements,
SelectClauseSpecRaw selectClauseSpec,
ExprNode optionalHavingNode,
java.util.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(java.util.Map<ExprNode,java.lang.Integer> expressionToIndex) |
GroupByRollupNodeCombinedExpr(java.util.List<ExprNode> expressions) |
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 |
---|---|
java.util.LinkedHashMap<java.lang.String,java.util.List<ExprNode>> |
AggregationValidationContext.getNamedParameters()
Returns any named parameters or null if there are no named parameters
|
Modifier and Type | Method and Description |
---|---|
static AggregationMultiFunctionAnalysisResult |
AggregationMultiFunctionAnalysisHelper.analyzeAccessAggregations(java.util.List<AggregationServiceAggExpressionDesc> aggregations,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName,
ExprNode[] groupByNodes) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
java.util.List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
java.lang.String statementName,
TimeAbacus timeAbacus) |
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
java.util.List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
java.lang.String statementName,
TimeAbacus timeAbacus) |
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
Modifier and Type | Method and Description |
---|---|
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
java.util.List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
java.lang.String statementName,
TimeAbacus timeAbacus) |
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(java.lang.Class[] parameterTypes,
boolean[] constantValue,
java.lang.Object[] constantValues,
boolean distinct,
boolean windowed,
ExprNode[] expressions,
java.util.LinkedHashMap<java.lang.String,java.util.List<ExprNode>> namedParameters)
Ctor.
|
Constructor and Description |
---|
AggregationValidationContext(java.lang.Class[] parameterTypes,
boolean[] constantValue,
java.lang.Object[] constantValues,
boolean distinct,
boolean windowed,
ExprNode[] expressions,
java.util.LinkedHashMap<java.lang.String,java.util.List<ExprNode>> namedParameters)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
AggGroupByDesc.getGroupByNodes() |
Constructor and Description |
---|
AggGroupByDesc(AggregationRowStateForgeDesc rowStateForgeDescs,
boolean isJoin,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
ExprNode[] groupByNodes) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
AggSvcGroupByWTableBase.accessStateExpr |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
AggregationGroupByLocalGroupLevel.getPartitionExpr() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlanForge |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationStateFactoryForge[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPairForge[] accessors,
EngineImportService engineImportService,
boolean fireAndForget,
java.lang.String statementName) |
Constructor and Description |
---|
AggregationGroupByLocalGroupLevel(ExprNode[] partitionExpr,
java.util.List<AggregationServiceAggExpressionDesc> expressions) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
EngineImportApplicationDotMethod.getLhs() |
ExprNode[] |
EngineImportApplicationDotMethod.getRhs() |
ExprNode |
EngineImportServiceImpl.resolveAggExtendedBuiltin(java.lang.String name,
boolean isDistinct) |
ExprNode |
EngineImportService.resolveAggExtendedBuiltin(java.lang.String name,
boolean isDistinct)
Resolve an extended (non-SQL std) builtin aggregation.
|
ExprNode |
EngineImportServiceImpl.resolveSingleRowExtendedBuiltin(java.lang.String name) |
ExprNode |
EngineImportService.resolveSingleRowExtendedBuiltin(java.lang.String name)
Resolve an extended (non-SQL std) single-row function.
|
ExprNode |
EngineImportApplicationDotMethod.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
OrderByElementForge.getExprNode() |
ExprNode |
OrderByElementEval.getExprNode() |
Constructor and Description |
---|
OrderByElementEval(ExprNode exprNode,
ExprEvaluator expr,
boolean descending) |
OrderByElementForge(ExprNode exprNode,
boolean isDescending) |
Modifier and Type | Method and Description |
---|---|
void |
MethodPollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
ResultSetProcessorAggregateGroupedForge.getGroupKeyNodeExpressions() |
ExprNode[] |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNodeExpressions() |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
GroupByRollupInfo.getExprNodes() |
static ExprNode |
ColumnNamedNodeSwapper.swap(ExprNode exprTree,
java.lang.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.makeOutputConditionExpression(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
java.util.List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionExpression(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> thenExpressions,
StatementContext statementContext,
ExprNode andAfterTerminateExpr,
java.util.List<OnTriggerSetAssignment> andAfterTerminateThenExpressions,
boolean isStartConditionOnCreation) |
static ExprNode |
ColumnNamedNodeSwapper.swap(ExprNode exprTree,
java.lang.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(java.util.List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionFactory |
ResultSetProcessorHelperFactory.makeOutputConditionCrontab(java.util.List<ExprNode> crontabAtSchedule,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
Constructor and Description |
---|
GroupByRollupInfo(ExprNode[] exprNodes,
AggregationGroupByRollupDesc rollupDesc) |
Modifier and Type | Method and Description |
---|---|
static CodegenMethodNode |
ResultSetProcessorGroupedUtil.generateGroupKeyArrayJoinCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
static CodegenMethodNode |
ResultSetProcessorGroupedUtil.generateGroupKeyArrayViewCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
static CodegenMethodNode |
ResultSetProcessorGroupedUtil.generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
ResultSetProcessorRowPerGroupForge.getGroupKeyNodeExpressions() |
ExprNode[] |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNodeExpressions() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
ResultSetProcessorRowPerGroupRollupForge.getGroupKeyNodeExpressions() |
ExprNode[] |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNodeExpressions() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupRollupFactory(EventType resultEventType,
GroupByRollupPerLevelExpression perLevelExpression,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams,
boolean unbounded) |
ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType,
GroupByRollupPerLevelForge perLevelForges,
ExprNode[] groupKeyNodeExpressions,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams) |
Modifier and Type | Method and Description |
---|---|
SelectExprProcessorForge |
SelectExprProcessorRepresentationFactory.makeRecast(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
AvroSchemaEventType insertIntoTargetType,
ExprNode[] exprNodes,
java.lang.String statementName,
java.lang.String engineURI) |
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessorForge |
EvalSelectStreamWUndRecastObjectArrayFactory.make(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService,
java.lang.String statementName,
java.lang.String engineURI) |
static SelectExprProcessorForge |
EvalSelectStreamWUndRecastMapFactory.make(EventType[] eventTypes,
SelectExprForgeContext selectExprForgeContext,
int streamNumber,
EventType targetType,
ExprNode[] exprNodes,
EngineImportService engineImportService,
java.lang.String statementName,
java.lang.String engineURI) |
Modifier and Type | Method and Description |
---|---|
static CalendarFieldEnum |
CalendarOpUtil.getEnum(java.lang.String methodName,
ExprNode exprNode) |
static java.lang.Object |
CalendarOpUtil.getFormatter(EPType inputType,
java.lang.String methodName,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
CalendarForge |
CalendarForgeFactory.getOp(DatetimeMethodEnum method,
java.lang.String methodNameUsed,
java.util.List<ExprNode> parameters,
ExprForge[] forges) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
FilterExprAnalyzerDTIntervalAffector.getIndexExpressions() |
ExprNode[] |
FilterExprAnalyzerDTBetweenAffector.getIndexExpressions() |
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<ExprNode,int[]>> |
FilterExprAnalyzerDTIntervalAffector.getKeyExpressions() |
java.util.List<Pair<ExprNode,int[]>> |
FilterExprAnalyzerDTBetweenAffector.getKeyExpressions() |
Modifier and Type | Method and Description |
---|---|
static ExprDotDTMethodDesc |
ExprDotDTFactory.validateMake(StreamTypeService streamTypeService,
java.util.Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
java.lang.String dtMethodName,
EPType inputType,
java.util.List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
FilterExprAnalyzerDTBetweenAffector(EventType[] typesPerStream,
int targetStreamNum,
java.lang.String targetPropertyName,
ExprNode start,
ExprNode end,
boolean includeLow,
boolean includeHigh) |
Modifier and Type | Method and Description |
---|---|
FilterExprAnalyzerDTIntervalAffector |
IntervalForgeImpl.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc)
Obtain information used by filter analyzer to handle this dot-method invocation as part of query planning/indexing.
|
FilterExprAnalyzerDTIntervalAffector |
IntervalForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
IntervalForge |
IntervalForgeFactory.getForge(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
java.lang.String methodNameUsed,
java.util.List<ExprNode> parameters,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputerForge |
IntervalComputerForgeFactory.make(DatetimeMethodEnum method,
java.util.List<ExprNode> expressions,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalForgeImpl(DatetimeMethodEnum method,
java.lang.String methodNameUse,
StreamTypeService streamTypeService,
java.util.List<ExprNode> expressions,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ReformatBetweenNonConstantParamsForge.end |
protected ExprNode |
ReformatBetweenNonConstantParamsForge.start |
Modifier and Type | Method and Description |
---|---|
FilterExprAnalyzerAffector |
ReformatToMillisecForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatToCalendarForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatStringFormatForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatGetFieldForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatFormatToDateForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatFormatForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatEvalForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatBetweenNonConstantParamsForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
FilterExprAnalyzerAffector |
ReformatBetweenConstantParamsForge.getFilterDesc(EventType[] typesPerStream,
DatetimeMethodEnum currentMethod,
java.util.List<ExprNode> currentParameters,
ExprDotNodeFilterAnalyzerInput inputDesc) |
ReformatForge |
ReformatForgeFactory.getForge(EPType inputType,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
DatetimeMethodEnum method,
java.lang.String methodNameUsed,
java.util.List<ExprNode> parameters,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ReformatBetweenConstantParamsForge(java.util.List<ExprNode> parameters,
java.util.TimeZone timeZone) |
ReformatBetweenNonConstantParamsForge(java.util.List<ExprNode> parameters,
java.util.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,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprDeclaredNode
Expression instance as declared elsewhere.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprDeclaredNodeImpl
Expression instance as declared elsewhere.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDeclaredNodeImpl.getBody() |
ExprNode |
ExprDeclaredNode.getBody() |
ExprNode |
ExprDeclaredNodeImpl.getExpressionBodyCopy() |
ExprNode |
ExprDeclaredForgeBase.getForgeRenderable() |
ExprNode |
ExprDeclaredNodeImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ExprNode> |
ExprDeclaredNodeImpl.getAdditionalNodes() |
java.util.List<ExprNode> |
ExprDeclaredNodeImpl.getChainParameters() |
java.util.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(java.lang.String name,
java.util.List<ExprNode> parameters,
java.util.Collection<ExpressionDeclItem> expressionDeclarations,
ExprDeclaredService exprDeclaredService,
ContextDescriptor contextDescriptor) |
static ExprNodeScript |
ExprDeclaredHelper.getExistsScript(java.lang.String defaultDialect,
java.lang.String expressionName,
java.util.List<ExprNode> parameters,
java.util.Collection<ExpressionScriptProvided> scriptExpressions,
ExprDeclaredService exprDeclaredService) |
Constructor and Description |
---|
ExprDeclaredNodeImpl(ExpressionDeclItem prototype,
java.util.List<ExprNode> chainParameters,
ContextDescriptor contextDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
ExprLambdaGoesNode
Represents the case-when-then-else control flow function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDotEvalParam.getBody() |
ExprNode |
ExprLambdaGoesNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprLambdaGoesNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Method and Description |
---|---|
void |
ExprDotForgeEnumMethodBase.init(java.lang.Integer streamOfProviderIfApplicable,
EnumMethodEnum enumMethodEnum,
java.lang.String enumMethodUsedName,
EPType typeInfo,
java.util.List<ExprNode> parameters,
ExprValidationContext validationContext) |
void |
ExprDotForgeEnumMethod.init(java.lang.Integer streamOfProviderIfApplicable,
EnumMethodEnum lambda,
java.lang.String lambdaUsedName,
EPType currentInputType,
java.util.List<ExprNode> parameters,
ExprValidationContext validationContext) |
Constructor and Description |
---|
ExprDotEvalParam(int parameterNum,
ExprNode body,
ExprForge bodyForge) |
ExprDotEvalParamExpr(int parameterNum,
ExprNode body,
ExprForge bodyForge) |
ExprDotEvalParamLambda(int parameterNum,
ExprNode body,
ExprForge bodyEvaluator,
int streamCountIncoming,
java.util.List<java.lang.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 AggregationAgentForge |
ExprAggAggregationAgentFactory.make(int streamNum,
ExprNode optionalFilter,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
static int |
ExprAggMultiFunctionUtil.validateStreamWildcardGetStreamNum(ExprNode node) |
Constructor and Description |
---|
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprNode[] expressions,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprForge optionalFilter,
boolean join) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAggregateNode
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAggregateNodeBase
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
class |
ExprAggregateNodeGroupKey |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExprAggregateNodeBase.optionalFilter |
protected ExprNode[] |
ExprAggregateNodeBase.positionalParams |
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprAggregateNodeGroupKey.getForgeRenderable() |
ExprNode |
ExprAggregateNodeBase.getForgeRenderable() |
ExprNode |
ExprAggregateNodeParamDesc.getOptionalFilter() |
ExprNode |
ExprAggregateNodeBase.getOptionalFilter() |
ExprNode |
ExprAggregateNode.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,
java.util.List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode[] nodes,
java.util.List<ExprAggregateNode> aggregateNodes) |
static void |
ExprAggregateNodeUtil.getAggregatesBottomUp(ExprNode topNode,
java.util.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(java.util.List<ExprNode> args) |
Constructor and Description |
---|
ExprAggregateLocalGroupByDesc(ExprNode[] partitionExpressions) |
ExprAggregateNodeParamDesc(ExprNode[] positionalParams,
ExprAggregateLocalGroupByDesc optLocalGroupBy,
ExprNode optionalFilter) |
ExprAggregateNodeParamDesc(ExprNode[] positionalParams,
ExprAggregateLocalGroupByDesc optLocalGroupBy,
ExprNode optionalFilter) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprConstantNode
Represents a constant in an expressiun tree.
|
interface |
ExprIdentNode
Represents an stream property identifier in a filter expressiun tree.
|
interface |
ExprStreamRefNode
Represents a stream-reference.
|
interface |
ExprStreamUnderlyingNode
Represents an stream selector that returns the streams underlying event, or null if undefined.
|
interface |
ExprVariableNode
Represents a variable in an expression tree.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprConstantNodeImpl
Represents a constant in an expressiun tree.
|
class |
ExprContextPropertyNodeImpl
Represents an stream property identifier in a filter expressiun tree.
|
class |
ExprCurrentEvaluationContextNode
Represents the "current_evaluation_context" function in an expression tree.
|
class |
ExprGroupingIdNode |
class |
ExprGroupingNode |
class |
ExprIdentNodeImpl
Represents an stream property identifier in a filter expressiun tree.
|
class |
ExprNamedParameterNodeImpl |
class |
ExprNodeBase
Superclass for filter nodes in a filter expression tree.
|
class |
ExprNodeValidated
A placeholder for another expression node that has been validated already.
|
class |
ExprNumberSetCronParam
Expression for a parameter within a crontab.
|
class |
ExprNumberSetFrequency
Expression for use within crontab to specify a frequency.
|
class |
ExprNumberSetList
Expression for use within crontab to specify a list of values.
|
class |
ExprNumberSetRange
Expression for use within crontab to specify a range.
|
class |
ExprOrderedExpr
A placeholder expression for view/pattern object parameters that allow
sorting expression values ascending or descending.
|
class |
ExprStreamUnderlyingNodeImpl
Represents an stream selector that returns the streams underlying event, or null if undefined.
|
class |
ExprSubstitutionNode
Represents a substitution value to be substituted in an expression tree, not valid for any purpose of use
as an expression, however can take a place in an expression tree.
|
class |
ExprTypedNoEvalNode
Represents an expression node that returns the predefined type and
that cannot be evaluated.
|
class |
ExprVariableNodeImpl
Represents a variable in an expression tree.
|
class |
ExprWildcardImpl
Expression for use within crontab to specify a wildcard.
|
Modifier and Type | Field and Description |
---|---|
static ExprNode[] |
ExprNodeUtility.EMPTY_EXPR_ARRAY |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ExprNodeUtility.addExpression(ExprNode[] expressions,
ExprNode expression) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(java.util.List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAndWhenNeeded(java.util.Collection<ExprNode> nodes) |
ExprNode[] |
ExprNodeBase.getChildNodes() |
ExprNode[] |
ExprNode.getChildNodes()
Returns list of child nodes.
|
ExprNode[] |
ExprNamedParameterNode.getChildNodes() |
ExprNode |
ExprStreamUnderlyingNodeImpl.getForgeRenderable() |
ExprNode |
ExprNamedParameterNodeImpl.getForgeRenderable() |
ExprNode |
ExprNodeProxy.getOriginalObject() |
ExprNode |
ExprNodePropOrStreamExprDesc.getOriginator() |
static ExprNode |
ExprNodeUtility.getValidatedAssignment(OnTriggerSetAssignment assignment,
ExprValidationContext validationContext) |
static ExprNode |
ExprNodeUtility.getValidatedSubtree(ExprNodeOrigin origin,
ExprNode exprNode,
ExprValidationContext validationContext)
Validates the expression node subtree that has this
node as root.
|
static ExprNode[] |
ExprNodeUtility.toArray(java.util.Collection<ExprNode> expressions) |
ExprNode |
ExprWildcardImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprVariableNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprValidator.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTypedNoEvalNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprSubstitutionNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprStreamUnderlyingNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprOrderedExpr.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetRange.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetList.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetFrequency.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNumberSetCronParam.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNodeValidated.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNamedParameterNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprIdentNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprGroupingNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprGroupingIdNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCurrentEvaluationContextNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprContextPropertyNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprConstantNodeImpl.validate(ExprValidationContext validationContext) |
static ExprNode |
ExprNodeUtility.validateSimpleGetSubtree(ExprNodeOrigin origin,
ExprNode expression,
StatementContext statementContext,
EventType optionalEventType,
boolean allowBindingConsumption) |
Modifier and Type | Method and Description |
---|---|
static Pair<java.lang.String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToProp(ExprNode node) |
static Pair<java.lang.String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToVariableOrProp(ExprNode node) |
static java.util.List<ExprNode> |
ExprNodeUtility.collectChainParameters(java.util.List<ExprChainedSpec> chainSpec) |
static java.util.List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
static java.util.List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
java.util.List<ExprNode> |
ExprNodeInnerNodeProvider.getAdditionalNodes() |
java.util.List<ExprNode> |
ExprChainedSpec.getParameters() |
Modifier and Type | Method and Description |
---|---|
static void |
ExprNodeUtility.acceptChain(ExprNodeVisitorWithParent visitor,
java.util.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.
|
static void |
ExprNodeUtility.acceptParams(ExprNodeVisitorWithParent visitor,
java.util.List<ExprNode> params,
ExprNode parent) |
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<java.lang.String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToProp(ExprNode node) |
static Pair<java.lang.String,ExprNode> |
ExprNodeUtility.checkGetAssignmentToVariableOrProp(ExprNode node) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(java.util.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) |
static boolean |
ExprNodeUtility.deepEqualsNullChecked(ExprNode nodeOne,
ExprNode nodeTwo,
boolean ignoreStreamPrefix) |
boolean |
ExprWildcardImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprVariableNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTypedNoEvalNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprSubstitutionNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprStreamUnderlyingNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprOrderedExpr.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetRange.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetList.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetFrequency.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNumberSetCronParam.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNodeValidated.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix)
Return true if a expression node semantically equals the current node, or false if not.
|
boolean |
ExprNamedParameterNodeImpl.equalsNode(ExprNode other,
boolean ignoreStreamPrefix) |
boolean |
ExprIdentNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprGroupingNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprGroupingIdNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprCurrentEvaluationContextNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprContextPropertyNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprConstantNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
static java.util.List<Pair<ExprNode,ExprNode>> |
ExprNodeUtility.findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(ExprNode[] exprNodes,
EngineImportService engineImportService,
java.lang.Class requestor,
boolean isFireAndForget,
java.lang.String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(ExprNode[] exprNodes) |
static java.util.List<Pair<java.lang.Integer,java.lang.String>> |
ExprNodeUtility.getExpressionProperties(ExprNode exprNode,
boolean visitAggregateNodes)
Walk expression returning properties used.
|
static java.lang.Class[] |
ExprNodeUtility.getExprResultTypes(ExprNode[] nodes) |
static ExprForge[] |
ExprNodeUtility.getForges(ExprNode[] exprNodes) |
static ExprNodePropOrStreamSet |
ExprNodeUtility.getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes) |
static java.lang.String[] |
ExprNodeUtility.getIdentResolvedPropertyNames(ExprNode[] nodes) |
static java.util.Set<java.lang.Integer> |
ExprNodeUtility.getIdentStreamNumbers(ExprNode child) |
static java.util.Set<java.lang.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 java.lang.String |
ExprNodeUtility.isMinimalExpression(ExprNode expression)
Check if the expression is minimal: does not have a subselect, aggregation and does not need view resources
|
static java.lang.Object |
ExprNodeProxy.newInstance(java.lang.String engineURI,
java.lang.String statementName,
ExprNode exprNode) |
static void |
ExprNodeUtility.replaceChainChildNode(ExprNode nodeToReplace,
ExprNode newNode,
java.util.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,
java.io.StringWriter buffer) |
static java.lang.String[] |
ExprNodeUtility.toExpressionStringMinPrecedenceAsArray(ExprNode[] nodes) |
static java.lang.String |
ExprNodeUtility.toExpressionStringMinPrecedenceAsList(ExprNode[] nodes) |
static void |
ExprNodeUtility.toExpressionStringMinPrecedenceAsList(ExprNode[] nodes,
java.io.StringWriter writer) |
static java.lang.String |
ExprNodeUtility.toExpressionStringMinPrecedenceSafe(ExprNode node) |
static void |
ExprNodeUtility.toExpressionStringParameterList(ExprNode[] childNodes,
java.io.StringWriter buffer) |
static void |
ExprNodeUtility.toExpressionStringParams(java.io.StringWriter writer,
ExprNode[] params) |
static java.lang.String[] |
ExprNodeUtility.toExpressionStringsMinPrecedence(ExprNode[] expressions) |
static void |
ExprNodeUtility.toExpressionStringWFunctionName(java.lang.String functionName,
ExprNode[] childNodes,
java.io.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 |
---|---|
static void |
ExprNodeUtility.acceptParams(ExprNodeVisitor visitor,
java.util.List<ExprNode> params) |
static void |
ExprNodeUtility.acceptParams(ExprNodeVisitorWithParent visitor,
java.util.List<ExprNode> params) |
static void |
ExprNodeUtility.acceptParams(ExprNodeVisitorWithParent visitor,
java.util.List<ExprNode> params,
ExprNode parent) |
void |
ExprNodeBase.addChildNodes(java.util.Collection<ExprNode> childNodeColl) |
void |
ExprNode.addChildNodes(java.util.Collection<ExprNode> childNodes)
Adds child nodes.
|
static void |
ExprNodeUtility.applyFilterExpressionsIterable(java.lang.Iterable<EventBean> iterable,
java.util.List<ExprNode> filterExpressions,
ExprEvaluatorContext exprEvaluatorContext,
java.util.Collection<EventBean> eventsInWindow) |
static ExprAndNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(java.util.Collection<ExprNode> nodes) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAnd(java.util.List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static ExprNode |
ExprNodeUtility.connectExpressionsByLogicalAndWhenNeeded(java.util.Collection<ExprNode> nodes) |
static ExprEvaluator[] |
ExprNodeUtility.crontabScheduleValidate(ExprNodeOrigin origin,
java.util.List<ExprNode> scheduleSpecExpressionList,
StatementContext context,
boolean allowBindingConsumption) |
static boolean |
ExprNodeUtility.deepEquals(java.util.List<ExprNode> one,
java.util.List<ExprNode> two) |
static boolean |
ExprNodeUtility.deepEquals(java.util.List<ExprNode> one,
java.util.List<ExprNode> two) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(java.util.List<ExprNode> exprNodes,
EngineImportService engineImportService,
java.lang.Class requestor,
boolean isFireAndForget,
java.lang.String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(java.util.List<ExprNode> childNodes) |
static java.lang.Class[] |
ExprNodeUtility.getExprResultTypes(java.util.List<ExprNode> expressions) |
static java.util.Map<java.lang.String,ExprNamedParameterNode> |
ExprNodeUtility.getNamedExpressionsHandleDups(java.util.List<ExprNode> parameters) |
static ExprNodePropOrStreamSet |
ExprNodeUtility.getNonAggregatedProps(EventType[] types,
java.util.List<ExprNode> exprNodes,
ContextPropertyRegistry contextPropertyRegistry) |
static boolean |
ExprNodeUtility.hasStreamSelect(java.util.List<ExprNode> exprNodes) |
static boolean |
ExprNodeUtility.isAllConstants(java.util.List<ExprNode> parameters) |
static ExprNodeUtilMethodDesc |
ExprNodeUtility.resolveMethodAllowWildcardAndStream(java.lang.String className,
java.lang.Class optionalClass,
java.lang.String methodName,
java.util.List<ExprNode> parameters,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
int statementId,
boolean allowWildcard,
EventType wildcardType,
ExprNodeUtilResolveExceptionHandler exceptionHandler,
java.lang.String functionName,
TableService tableService,
java.lang.String engineURI) |
void |
ExprChainedSpec.setParameters(java.util.List<ExprNode> parameters) |
static ExprNode[] |
ExprNodeUtility.toArray(java.util.Collection<ExprNode> expressions) |
static void |
ExprNodeUtility.toExpressionStringIncludeParen(java.util.List<ExprNode> parameters,
java.io.StringWriter buffer) |
static void |
ExprNodeUtility.toExpressionStringParameterList(java.util.List<ExprNode> parameters,
java.io.StringWriter buffer) |
Constructor and Description |
---|
ExprNodePropOrStreamExprDesc(int streamNum,
ExprNode originator) |
ExprNodeProxy(java.lang.String engineURI,
java.lang.String statementName,
ExprNode exprNode) |
ExprNodeValidated(ExprNode inner)
Ctor.
|
Constructor and Description |
---|
ExprChainedSpec(java.lang.String name,
java.util.List<ExprNode> parameters,
boolean property) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprDotNode
Represents an Dot-operator expression, for use when "(expression).method(...).method(...)"
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAppDotMethodImpl |
class |
ExprDotNodeImpl
Represents an Dot-operator expression, for use when "(expression).method(...).method(...)"
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprDotNodeForgeStaticMethod.getForgeRenderable() |
ExprNode |
ExprDotNodeForgePropertyExpr.getForgeRenderable() |
ExprNode |
ExprDotNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprAppDotMethodImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ExprNode> |
ExprDotNodeImpl.getAdditionalNodes() |
Modifier and Type | Method and Description |
---|---|
void |
ExprDotNodeImpl.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
boolean |
ExprDotNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprAppDotMethodImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
static ExprDotEnumerationSourceForge |
ExprDotNodeUtility.getEnumerationSource(ExprNode inputExpression,
StreamTypeService streamTypeService,
EventAdapterService eventAdapterService,
int statementId,
boolean hasEnumerationMethod,
boolean disablePropertyExpressionEventCollCache) |
void |
ExprDotNodeImpl.replaceUnlistedChildNode(ExprNode nodeToReplace,
ExprNode newNode) |
Constructor and Description |
---|
ExprDotNodeForgeStaticMethod(ExprNode parent,
boolean isReturnsConstantResult,
java.lang.String statementName,
java.lang.String classOrPropertyName,
net.sf.cglib.reflect.FastMethod staticMethod,
ExprForge[] childForges,
boolean isConstantParameters,
ExprDotForge[] chainForges,
ExprDotStaticMethodWrap resultWrapLambda,
boolean rethrowExceptions,
java.lang.Object targetObject) |
Modifier and Type | Class and Description |
---|---|
class |
ExprCaseNode
Represents the case-when-then-else control flow function is an expression tree.
|
class |
ExprCastNode
Represents the CAST(expression, type) function is an expression tree.
|
class |
ExprCoalesceNode
Represents the COALESCE(a,b,...) function is an expression tree.
|
class |
ExprInstanceofNode
Represents the INSTANCEOF(a,b,...) function is an expression tree.
|
class |
ExprIStreamNode
Represents the RSTREAM() function in an expression tree.
|
class |
ExprMinMaxRowNode
Represents the MAX(a,b) and MIN(a,b) functions is an expression tree.
|
class |
ExprPlugInSingleRowNode
Represents an invocation of a plug-in single-row function in the expression tree.
|
class |
ExprPropertyExistsNode
Represents the EXISTS(property) function in an expression tree.
|
class |
ExprTypeofNode
Represents the TYPEOF(a) function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTypeofNodeForgeStreamEvent.getForgeRenderable() |
ExprNode |
ExprTypeofNodeForgeFragmentType.getForgeRenderable() |
ExprNode |
ExprPropertyExistsNode.getForgeRenderable() |
ExprNode |
ExprIStreamNode.getForgeRenderable() |
ExprNode |
ExprCaseNodeForge.getOptionalCompareExprNode() |
ExprNode |
ExprCaseNode.CaseAnalysis.getOptionalCompareExprNode() |
ExprNode |
ExprCaseNodeForge.getOptionalElseExprNode() |
ExprNode |
ExprCaseNode.CaseAnalysis.getOptionalElseExprNode() |
ExprNode |
ExprTypeofNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPropertyExistsNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPlugInSingleRowNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprMinMaxRowNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprIStreamNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprInstanceofNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCoalesceNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCastNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprCaseNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ExprNode> |
ExprPlugInSingleRowNode.getAdditionalNodes() |
java.util.List<UniformPair<ExprNode>> |
ExprCaseNodeForge.getWhenThenNodeList() |
java.util.List<UniformPair<ExprNode>> |
ExprCaseNode.CaseAnalysis.getWhenThenNodeList() |
Modifier and Type | Method and Description |
---|---|
void |
ExprPlugInSingleRowNode.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
protected static CodegenExpression |
ExprCaseNodeForgeEvalSyntax1.codegenToType(ExprCaseNodeForge forge,
ExprNode node,
CodegenMethodNode methodNode,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
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(java.util.List<UniformPair<ExprNode>> whenThenNodeList,
ExprNode optionalCompareExprNode,
ExprNode optionalElseExprNode) |
Constructor and Description |
---|
CaseAnalysis(java.util.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 |
ExprFirstLastEverNode
Represents the "firstever" and "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 ExprForge[] |
ExprMethodAggUtil.getDefaultForges(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
static ExprEvaluator |
ExprMethodAggUtil.getMultiNodeEvaluator(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAndNode
Represents an And-condition.
|
interface |
ExprBetweenNode
Represents the between-clause function in an expression tree.
|
interface |
ExprEqualsNode
Represents an equals (=, !=, <>, is, is not) comparator in a filter expressiun tree.
|
interface |
ExprInNode
Represents the in-clause (set check) function in an expression tree.
|
interface |
ExprRelationalOpNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAndNodeImpl
Represents an And-condition.
|
class |
ExprArrayNode
Represents an array in a filter expressiun tree.
|
class |
ExprBetweenNodeImpl
Represents the between-clause function in an expression tree.
|
class |
ExprBitWiseNode
Represents the bit-wise operators in an expression tree.
|
class |
ExprConcatNode
Represents a string concatenation.
|
class |
ExprEqualsAllAnyNode
Represents an equals-for-group (= ANY/ALL/SOME (expression list)) comparator in a expression tree.
|
class |
ExprEqualsNodeImpl
Represents an equals (=) comparator in a filter expressiun tree.
|
class |
ExprInNodeImpl
Represents the in-clause (set check) function in an expression tree.
|
class |
ExprLikeNode
Represents the like-clause in an expression tree.
|
class |
ExprMathNode
Represents a simple Math (+/-/divide/*) in a filter expression tree.
|
class |
ExprNewInstanceNode
Represents the "new Class(...)" operator in an expression tree.
|
class |
ExprNewStructNode
Represents the "new {...}" operator in an expression tree.
|
class |
ExprNotNode
Represents a NOT expression in an expression tree.
|
class |
ExprOrNode
Represents an OR expression in a filter expression tree.
|
class |
ExprRegexpNode
Represents the regexp-clause in an expression tree.
|
class |
ExprRelationalOpAllAnyNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
class |
ExprRelationalOpNodeImpl
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprOrNode.getForgeRenderable() |
ExprNode |
ExprNotNode.getForgeRenderable() |
ExprNode |
ExprRelationalOpNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprRelationalOpAllAnyNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprRegexpNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprOrNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNotNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNewStructNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprNewInstanceNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprMathNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprLikeNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprInNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprEqualsNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprEqualsAllAnyNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprConcatNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprBitWiseNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprBetweenNodeImpl.validate(ExprValidationContext validationContext) |
ExprNode |
ExprArrayNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprAndNodeImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
ExprBitWiseNodeForgeEval.codegen(ExprBitWiseNodeForge forge,
java.lang.Class requiredType,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode lhs,
ExprNode rhs) |
static CodegenMethodNode |
ExprEqualsNodeForgeCoercionEval.codegen(ExprEqualsNodeForgeCoercion forge,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode lhs,
ExprNode rhs) |
static CodegenMethodNode |
ExprLikeNodeForgeConstEval.codegen(ExprLikeNodeForgeConst forge,
ExprNode lhs,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
static CodegenMethodNode |
ExprLikeNodeFormNonconstEval.codegen(ExprLikeNodeForgeNonconst forge,
ExprNode lhs,
ExprNode pattern,
ExprNode optionalEscape,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
static CodegenMethodNode |
ExprMathNodeForgeEval.codegen(ExprMathNodeForge forge,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode lhs,
ExprNode rhs) |
static CodegenMethodNode |
ExprRegexpNodeForgeConstEval.codegen(ExprRegexpNodeForgeConst forge,
ExprNode lhs,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
static CodegenMethodNode |
ExprRegexpNodeForgeNonconstEval.codegen(ExprRegexpNodeForgeNonconst forge,
ExprNode lhs,
ExprNode pattern,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope) |
boolean |
ExprRelationalOpNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprRelationalOpAllAnyNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprRegexpNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprOrNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNotNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNewStructNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprNewInstanceNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprMathNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprLikeNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprInNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprEqualsNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprEqualsAllAnyNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprConcatNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprBitWiseNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprBetweenNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprArrayNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprAndNodeImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPreviousMatchRecognizeNode
Represents the 'prev' previous event function in match-recognize "define" item.
|
class |
ExprPreviousNode
Represents the 'prev' previous event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprPreviousNode.getForgeRenderable() |
ExprNode |
ExprPreviousMatchRecognizeNode.getForgeRenderable() |
ExprNode |
ExprPreviousNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprPreviousMatchRecognizeNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprPreviousNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprPreviousMatchRecognizeNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPriorNode
Represents the 'prior' prior event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprPriorNode.getForgeRenderable() |
ExprNode |
ExprPriorNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprPriorNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Class and Description |
---|---|
class |
ExprSubselectAllSomeAnyNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectExistsNode
Represents an exists-subselect in an expression tree.
|
class |
ExprSubselectInNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectRowNode
Represents a subselect in an expression tree.
|
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
ExprSubselectNode.selectClause
The validated select clause.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
ExprSubselectNode.getSelectClause()
Returns the select clause or null if none.
|
ExprNode |
ExprSubselectNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprSubselectNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
void |
ExprSubselectNode.setSelectClause(ExprNode[] selectClause,
EngineImportService engineImportService,
java.lang.String statementName)
Sets the validates select clause
|
Modifier and Type | Class and Description |
---|---|
class |
ExprTableAccessNode |
class |
ExprTableAccessNodeKeys |
class |
ExprTableAccessNodeSubprop |
class |
ExprTableAccessNodeSubpropAccessor |
class |
ExprTableAccessNodeTopLevel |
class |
ExprTableIdentNode |
class |
ExprTableIdentNodeSubpropAccessor |
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTableIdentNode.getForgeRenderable() |
ExprNode |
ExprTableIdentNodeSubpropAccessor.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTableIdentNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTableAccessNode.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprTableIdentNodeSubpropAccessor.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTableIdentNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTableAccessNode.equalsNode(ExprNode o,
boolean ignoreStreamPrefix) |
static void |
ExprTableNodeUtil.validateExpressions(java.lang.String tableName,
java.lang.Class[] providedTypes,
java.lang.String providedName,
ExprNode[] providedExpr,
java.lang.Class[] expectedTypes,
java.lang.String expectedName) |
Constructor and Description |
---|
ExprTableAccessNodeSubpropAccessor(java.lang.String tableName,
java.lang.String subpropName,
ExprNode aggregateAccessMultiValueNode) |
ExprTableIdentNodeSubpropAccessor(int streamNum,
java.lang.String optionalStreamName,
TableMetadataColumnAggregation tableAccessColumn,
ExprNode aggregateAccessMultiValueNode) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprTimePeriod
Expression representing a time period.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprTimePeriodImpl
Expression representing a time period.
|
class |
ExprTimestampNode
Represents the CURRENT_TIMESTAMP() function or reserved keyword in an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprNode |
ExprTimestampNode.getForgeRenderable() |
ExprNode |
ExprTimestampNode.validate(ExprValidationContext validationContext) |
ExprNode |
ExprTimePeriodImpl.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExprTimestampNode.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
boolean |
ExprTimePeriodImpl.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ExprNode> |
ExprNodeViewResourceVisitor.getExprNodes()
Returns the list of expression nodes requiring view resources.
|
java.util.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.
|
java.util.List<Pair<ExprNode,ExprGroupingIdNode>> |
ExprNodeGroupingVisitorWParent.getGroupingIdNodes() |
java.util.List<Pair<ExprNode,ExprGroupingNode>> |
ExprNodeGroupingVisitorWParent.getGroupingNodes() |
java.util.List<Pair<ExprNode,ExprIdentNode>> |
ExprNodeIdentVisitorWParent.getIdentNodes() |
java.util.List<Pair<ExprNode,ExprPreviousNode>> |
ExprNodePreviousVisitorWParent.getPrevious()
Returns the pair of previous nodes and their parent expression.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ExprNodeVisitorWithParent.isVisit(ExprNode exprNode)
Allows visitor to indicate whether to visit a given node.
|
boolean |
ExprNodeVisitor.isVisit(ExprNode exprNode)
Allows visitor to indicate whether to visit a given node.
|
boolean |
ExprNodeViewResourceVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeVariableVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeTableAccessVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeTableAccessFinderVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSummaryVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSubselectDeclaredNoTraverseVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeSubselectDeclaredDotVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamUseCollectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamSelectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeStreamRequiredVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodePreviousVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierCollectVisitorWContainer.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierCollectVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeIdentifierAndStreamRefVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeGroupingVisitorWParent.isVisit(ExprNode exprNode) |
boolean |
ExprNodeDeclaredVisitor.isVisit(ExprNode exprNode) |
boolean |
ExprNodeContextPropertiesVisitor.isVisit(ExprNode exprNode) |
void |
ExprNodeVisitor.visit(ExprNode exprNode)
Visit the given expression node.
|
void |
ExprNodeViewResourceVisitor.visit(ExprNode exprNode) |
void |
ExprNodeVariableVisitor.visit(ExprNode exprNode) |
void |
ExprNodeTableAccessVisitor.visit(ExprNode exprNode) |
void |
ExprNodeTableAccessFinderVisitor.visit(ExprNode exprNode) |
void |
ExprNodeSummaryVisitor.visit(ExprNode exprNode) |
void |
ExprNodeSubselectDeclaredDotVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamUseCollectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamSelectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeStreamRequiredVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierCollectVisitor.visit(ExprNode exprNode) |
void |
ExprNodeIdentifierAndStreamRefVisitor.visit(ExprNode exprNode) |
void |
ExprNodeDeclaredVisitor.visit(ExprNode exprNode) |
void |
ExprNodeContextPropertiesVisitor.visit(ExprNode exprNode) |
void |
ExprNodeVisitorWithParent.visit(ExprNode exprNode,
ExprNode parentExprNode)
Visit the given expression node.
|
void |
ExprNodeSubselectDeclaredNoTraverseVisitor.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodePreviousVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodeIdentVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
void |
ExprNodeIdentifierCollectVisitorWContainer.visit(ExprNode exprNode,
ExprNode containerExprNode) |
void |
ExprNodeGroupingVisitorWParent.visit(ExprNode exprNode,
ExprNode parentExprNode) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
EngineImportApplicationDotMethodBase.getLhs() |
ExprNode[] |
EngineImportApplicationDotMethodBase.getRhs() |
ExprNode |
EngineImportApplicationDotMethodBase.validate(ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
protected ExprForge |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprForge |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprForge |
EngineImportApplicationDotMethodBase.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprForge |
EngineImportApplicationDotMethodBase.validateAll(java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
AdvancedIndexConfigContextPartition |
AdvancedIndexFactoryProviderQuadTree.validateConfigureFilterIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] parameters,
ExprValidationContext validationContext) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderPointRegionQuadTree.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderPointRegionQuadTree.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderMXCIFQuadTree.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProviderMXCIFQuadTree.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
protected static void |
AdvancedIndexFactoryProviderQuadTree.validateParameters(java.lang.String indexTypeName,
ExprNode[] parameters) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategyFactoryQuadTree |
EventAdvancedIndexFactoryQuadTree.getSubordinateLookupStrategy(java.lang.String operationName,
java.util.Map<java.lang.Integer,ExprNode> positionalExpressions,
boolean isNWOnTrigger,
int numOuterstreams) |
boolean |
EventAdvancedIndexFactoryQuadTreePointRegion.providesIndexForOperation(java.lang.String operationName,
java.util.Map<java.lang.Integer,ExprNode> value) |
boolean |
EventAdvancedIndexFactoryQuadTreeMXCIF.providesIndexForOperation(java.lang.String operationName,
java.util.Map<java.lang.Integer,ExprNode> value) |
Constructor and Description |
---|
EngineImportApplicationDotMethodBase(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodBase(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodBase(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodPointInsideRectange(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodPointInsideRectange(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodPointInsideRectange(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodRectangeIntersectsRectangle(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodRectangeIntersectsRectangle(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
EngineImportApplicationDotMethodRectangeIntersectsRectangle(ExprDotNodeImpl parent,
java.lang.String lhsName,
ExprNode[] lhs,
java.lang.String dotMethodName,
java.lang.String rhsName,
ExprNode[] rhs,
ExprNode[] indexNamedParameter) |
Modifier and Type | Method and Description |
---|---|
static void |
AdvancedIndexValidationHelper.validateColumnReturnTypeNumber(java.lang.String indexTypeName,
int colnum,
ExprNode expr,
java.lang.String name) |
AdvancedIndexConfigContextPartition |
AdvancedIndexFactoryProvider.validateConfigureFilterIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] parameters,
ExprValidationContext validationContext) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProvider.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
EventAdvancedIndexProvisionDesc |
AdvancedIndexFactoryProvider.validateEventIndex(java.lang.String indexName,
java.lang.String indexTypeName,
ExprNode[] columns,
ExprNode[] parameters) |
static void |
AdvancedIndexValidationHelper.validateParameterReturnType(java.lang.Class expectedReturnType,
java.lang.String indexTypeName,
int paramnum,
ExprNode expr,
java.lang.String name) |
static void |
AdvancedIndexValidationHelper.validateParameterReturnTypeNumber(java.lang.String indexTypeName,
int paramnum,
ExprNode expr,
java.lang.String name) |
Constructor and Description |
---|
FilterExprAnalyzerAffectorIndexProvision(java.lang.String operationName,
ExprNode[] indexExpressions,
java.util.List<Pair<ExprNode,int[]>> keyExpressions,
int streamNumIndex) |
Constructor and Description |
---|
FilterExprAnalyzerAffectorIndexProvision(java.lang.String operationName,
ExprNode[] indexExpressions,
java.util.List<Pair<ExprNode,int[]>> keyExpressions,
int streamNumIndex) |
Modifier and Type | Method and Description |
---|---|
static JoinSetComposerPrototype |
JoinSetComposerPrototypeFactory.makeComposerPrototype(java.lang.String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
java.lang.String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery,
boolean allowIndexInit) |
Constructor and Description |
---|
HistoricalIndexLookupStrategyInKeywordMulti(int lookupStream,
ExprNode expression) |
HistoricalIndexLookupStrategyInKeywordSingle(int lookupStream,
ExprNode[] expressions) |
JoinSetComposerPrototypeImpl(java.lang.String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
java.lang.String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
java.lang.annotation.Annotation[] annotations,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
QueryPlanIndex[] indexSpecs,
QueryPlan queryPlan,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean joinRemoveStream,
boolean isOuterJoins,
TableService tableService,
EventTableIndexService eventTableIndexService,
EngineImportService engineImportService,
boolean isFireAndForget) |
Constructor and Description |
---|
IndexedTableLookupStrategySingleExpr(ExprNode exprNode,
int streamNum,
PropertyIndexedEventTableSingle index,
LookupStrategyDesc strategyDesc) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExcludePlanHint.filter(int streamLookup,
int streamIndexed,
ExcludePlanFilterOperatorType opType,
ExprNode... exprNodes) |
static EventBean |
ExcludePlanHintExprUtil.toEvent(int fromStreamnum,
int toStreamnum,
java.lang.String fromStreamname,
java.lang.String toStreamname,
java.lang.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 |
---|---|
java.util.Map<java.lang.Integer,ExprNode> |
QueryGraphValueEntryCustomOperation.getPositionalExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
QueryGraphValue.addCustom(ExprNode[] indexExpressions,
java.lang.String operationName,
int expressionPosition,
ExprNode expression) |
void |
QueryGraphValue.addCustom(ExprNode[] indexExpressions,
java.lang.String operationName,
int expressionPosition,
ExprNode expression) |
void |
QueryGraph.addCustomIndex(java.lang.String operationName,
ExprNode[] indexExpressions,
java.util.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,
java.lang.Integer optionalStartStreamNum,
ExprNode endNode,
java.lang.Integer optionalEndStreamNum,
QueryGraphRangeEnum rangeOp) |
void |
QueryGraph.addRelationalOp(int indexedStream,
ExprIdentNode indexedProp,
java.lang.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 java.lang.Class |
CoercionUtil.getCoercionTypeRangeIn(java.lang.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(java.lang.String operationName,
ExprNode[] indexExpressions,
java.util.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,
java.util.List<SubordPropHashKey> hashKeys,
CoercionDesc hashKeyCoercionTypes,
java.util.List<SubordPropRangeKey> rangeKeys,
CoercionDesc rangeKeyCoercionTypes,
ExprNode[] inKeywordSingleIdxKeys,
ExprNode inKeywordMultiIdxKey,
boolean isNWOnTrigger) |
static SubordTableLookupStrategyFactory |
SubordinateTableLookupStrategyUtil.getLookupStrategy(EventType[] outerStreamTypesZeroIndexed,
java.util.List<SubordPropHashKey> hashKeys,
CoercionDesc hashKeyCoercionTypes,
java.util.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,
java.util.Set<java.lang.String> optionalUniqueKeyProps,
boolean onlyUseExistingIndexes,
java.lang.String statementName,
int statementId,
java.lang.annotation.Annotation[] annotations,
EngineImportService engineImportService) |
Modifier and Type | Method and Description |
---|---|
SubordTableLookupStrategyFactoryQuadTree |
EventAdvancedIndexFactory.getSubordinateLookupStrategy(java.lang.String operationName,
java.util.Map<java.lang.Integer,ExprNode> expressions,
boolean isNWOnTrigger,
int numOuterstreams) |
boolean |
EventAdvancedIndexFactory.providesIndexForOperation(java.lang.String operationName,
java.util.Map<java.lang.Integer,ExprNode> expressions) |
Constructor and Description |
---|
AdvancedIndexDesc(java.lang.String indexTypeName,
ExprNode[] indexedExpressions) |
SubordInKeywordMultiTableLookupStrategyFactory(boolean isNWOnTrigger,
int streamCountOuter,
ExprNode exprNode) |
SubordInKeywordSingleTableLookupStrategyFactory(boolean isNWOnTrigger,
int streamCountOuter,
ExprNode[] exprNodes) |
SubordPropInKeywordMultiIndex(java.lang.String[] indexedProp,
java.lang.Class coercionType,
ExprNode expression) |
SubordPropInKeywordSingleIndex(java.lang.String indexedProp,
java.lang.Class coercionType,
ExprNode[] expressions) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
DotMethodFPProvidedParam.getExpression() |
Modifier and Type | Method and Description |
---|---|
static DotMethodFPProvided |
DotMethodUtil.getProvidedFootprint(java.util.List<ExprNode> parameters) |
Constructor and Description |
---|
DotMethodFPProvidedParam(int lambdaParamNum,
java.lang.Class returnType,
ExprNode expression) |
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
NamedWindowConsumerDesc.getFilterExpressions() |
Modifier and Type | Method and Description |
---|---|
EventBean[] |
NamedWindowTailViewInstance.snapshotDelete(QueryGraph queryGraph,
ExprNode filterExpr,
java.lang.annotation.Annotation[] annotations) |
java.util.Collection<EventBean> |
NamedWindowTailViewInstance.snapshotNoLockWithFilter(QueryGraph queryGraph,
java.lang.annotation.Annotation[] annotations,
ExprNode filterExpr,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
NamedWindowTailViewInstance.snapshotUpdate(QueryGraph queryGraph,
ExprNode optionalWhereClause,
EventBeanUpdateHelper updateHelper,
java.lang.annotation.Annotation[] annotations) |
Constructor and Description |
---|
NamedWindowConsumerDesc(ExprNode[] filterExpressions,
ExprEvaluator[] filterEvaluators,
PropertyEvaluator optPropertyEvaluator,
AgentInstanceContext agentInstanceContext) |
NamedWindowOnMergeMatch(ExprNode optionalCond,
java.util.List<NamedWindowOnMergeAction> actions,
EngineImportService engineImportService,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ASTExprHelper.exprCollectSubNodesPerNode(java.util.List<EsperEPL2GrammarParser.ExpressionContext> expression,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprNode |
ASTExprHelper.mathGetExpr(org.antlr.v4.runtime.tree.ParseTree ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation configurationInformation) |
static ExprNode |
ASTExprHelper.resolvePropertyOrVariableIdentifier(java.lang.String identifier,
VariableService variableService,
StatementSpecRaw spec) |
static ExprNode |
ASTAggregationHelper.tryResolveAsAggregation(EngineImportService engineImportService,
boolean distinct,
java.lang.String functionName,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.String engineURI) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<ExprNode> |
ASTExprHelper.exprCollectSubNodes(org.antlr.v4.runtime.tree.Tree parentNode,
int startIndex,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static java.util.List<ExprNode> |
ASTLibFunctionHelper.getExprNodesLibFunc(EsperEPL2GrammarParser.LibFunctionArgsContext ctx,
java.util.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,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodes(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesAddParentNode(ExprNode exprNode,
org.antlr.v4.runtime.tree.Tree node,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesExpressionCtx(ExprNode parentNode,
java.util.List<EsperEPL2GrammarParser.ExpressionContext> expressionContexts,
java.util.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,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
java.lang.String engineURI,
TimeProvider timeProvider,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ASTExprHelper.exprCollectAddSingle(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodes(ExprNode parentNode,
org.antlr.v4.runtime.tree.Tree node,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesAddParentNode(ExprNode exprNode,
org.antlr.v4.runtime.tree.Tree node,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTExprHelper.exprCollectAddSubNodesExpressionCtx(ExprNode parentNode,
java.util.List<EsperEPL2GrammarParser.ExpressionContext> expressionContexts,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static java.util.List<ExprNode> |
ASTExprHelper.exprCollectSubNodes(org.antlr.v4.runtime.tree.Tree parentNode,
int startIndex,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprNode[] |
ASTExprHelper.exprCollectSubNodesPerNode(java.util.List<EsperEPL2GrammarParser.ExpressionContext> expression,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static java.util.List<CreateTableColumn> |
ASTTableHelper.getColumns(java.util.List<EsperEPL2GrammarParser.CreateTableColumnContext> ctxs,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
EngineImportService engineImportService) |
static java.util.List<ExprNode> |
ASTLibFunctionHelper.getExprNodesLibFunc(EsperEPL2GrammarParser.LibFunctionArgsContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static java.util.List<ExprChainedSpec> |
ASTLibFunctionHelper.getLibFuncChain(java.util.List<EsperEPL2GrammarParser.LibFunctionNoClassContext> ctxs,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static ExprChainedSpec |
ASTLibFunctionHelper.getLibFunctionChainSpec(EsperEPL2GrammarParser.LibFunctionNoClassContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
protected static java.util.List<OnTriggerSetAssignment> |
ASTExprHelper.getOnTriggerSetAssignments(EsperEPL2GrammarParser.OnSetAssignmentListContext ctx,
java.util.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,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
java.lang.String engineURI,
ExpressionDeclDesc expressionDeclarations,
ExprDeclaredService exprDeclaredService,
java.util.List<ExpressionScriptProvided> scriptExpressions,
ContextDescriptor contextDescriptor,
TableService tableService,
StatementSpecRaw statementSpec,
VariableService variableService) |
static ExprNode |
ASTExprHelper.mathGetExpr(org.antlr.v4.runtime.tree.ParseTree ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation configurationInformation) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprAllParams(EsperEPL2GrammarParser.TimePeriodContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
StatementSpecRaw spec,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprJustSeconds(EsperEPL2GrammarParser.ExpressionContext expression,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static CreateIndexDesc |
ASTIndexHelper.walk(EsperEPL2GrammarParser.CreateIndexExprContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static CreateContextDesc |
ASTContextHelper.walkCreateContext(EsperEPL2GrammarParser.CreateContextExprContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
java.util.Map<org.antlr.v4.runtime.tree.Tree,EvalFactoryNode> astPatternNodeMap,
PropertyEvalSpec propertyEvalSpec,
FilterSpecRaw filterSpec) |
static Pair<ExpressionDeclItem,ExpressionScriptProvided> |
ASTExpressionDeclHelper.walkExpressionDecl(EsperEPL2GrammarParser.ExpressionDeclContext ctx,
java.util.List<java.lang.String> scriptBodies,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
org.antlr.v4.runtime.CommonTokenStream tokenStream) |
static FilterSpecRaw |
ASTFilterSpecHelper.walkFilterSpec(EsperEPL2GrammarParser.EventFilterExpressionContext ctx,
PropertyEvalSpec propertyEvalSpec,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap) |
static void |
ASTGroupByHelper.walkGroupBy(EsperEPL2GrammarParser.GroupByListExprContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
java.util.List<GroupByClauseElement> groupByExpressions) |
static RowRegexExprRepeatDesc |
ASTMatchRecognizeHelper.walkOptionalRepeat(EsperEPL2GrammarParser.MatchRecogPatternRepeatContext ctx,
java.util.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 |
---|---|
java.util.List<ExprNode> |
ExprNodeScript.getAdditionalNodes() |
java.util.List<ExprNode> |
ExprNodeScript.getParameters() |
Modifier and Type | Method and Description |
---|---|
void |
ExprNodeScript.acceptChildnodes(ExprNodeVisitorWithParent visitor,
ExprNode parent) |
boolean |
ExprNodeScript.equalsNode(ExprNode node,
boolean ignoreStreamPrefix) |
Constructor and Description |
---|
ExprNodeScript(java.lang.String defaultDialect,
ExpressionScriptProvided script,
java.util.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 |
---|---|
java.util.List<ExprNode> |
ContextDetailConditionCrontab.getCrontab() |
java.util.List<ExprNode> |
OutputLimitSpec.getCrontabAtSchedule()
Returns crontab parameters, or null if not using crontab-at output.
|
java.util.List<ExprNode> |
MethodStreamSpec.getExpressions()
Returns the parameter expressions.
|
java.util.List<ExprNode> |
GroupByClauseElementCombinedExpr.getExpressions() |
java.util.List<ExprNode> |
ForClauseItemSpec.getExpressions() |
java.util.List<ExprNode> |
CreateIndexItem.getExpressions() |
java.util.List<ExprNode> |
TableQueryStreamSpec.getFilterExpressions() |
java.util.List<ExprNode> |
NamedWindowConsumerStreamSpec.getFilterExpressions()
Returns list of filter expressions onto the named window, or no filter expressions if none defined.
|
java.util.List<ExprNode> |
FilterSpecRaw.getFilterExpressions()
Returns the list of filter expressions.
|
java.util.List<ExprNode> |
ObjectSpec.getObjectParameters()
Returns the list of object parameters.
|
java.util.List<ExprNode> |
CreateIndexItem.getParameters() |
java.util.List<ExprNode> |
MatchRecognizeSpec.getPartitionByExpressions()
Returns partition expressions.
|
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> |
StatementSpecRaw.getSqlParameters() |
java.util.Map<java.lang.Integer,java.util.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(java.util.List<ExprNode> expressions) |
void |
MatchRecognizeSpec.setPartitionByExpressions(java.util.List<ExprNode> partitionByExpressions)
Returns partition expressions.
|
void |
StatementSpecRaw.setSqlParameters(java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters) |
Constructor and Description |
---|
ContextDetailCategoryItem(ExprNode expression,
java.lang.String name) |
ContextDetailInitiatedTerminated(ContextDetailCondition start,
ContextDetailCondition end,
boolean overlapping,
ExprNode[] distinctExpressions) |
CreateTableColumn(java.lang.String columnName,
ExprNode optExpression,
java.lang.String optTypeName,
java.lang.Boolean optTypeIsArray,
java.lang.Boolean optTypeIsPrimitiveArray,
java.util.List<AnnotationDesc> annotations,
java.lang.Boolean primaryKey) |
CreateVariableDesc(java.lang.String variableType,
java.lang.String variableName,
ExprNode assignment,
boolean constant,
boolean array,
boolean arrayOfPrimitive)
Ctor.
|
CreateWindowDesc(java.lang.String windowName,
java.util.List<ViewSpec> viewSpecs,
StreamSpecOptions streamSpecOptions,
boolean insert,
ExprNode insertFilter,
java.util.List<ColumnDesc> columns,
java.lang.String asEventTypeName)
Ctor.
|
ExpressionDeclItem(java.lang.String name,
java.util.List<java.lang.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(java.lang.String identifier,
ExprNode expression)
Ctor.
|
MatchRecognizeMeasureItem(ExprNode expr,
java.lang.String name)
Ctor.
|
NewItem(java.lang.String name,
ExprNode optExpression) |
OnTriggerMergeAction(ExprNode optionalWhereClause) |
OnTriggerMergeActionDelete(ExprNode optionalMatchCond) |
OnTriggerMergeActionInsert(ExprNode optionalWhereClause,
java.lang.String optionalStreamName,
java.util.List<java.lang.String> columns,
java.util.List<SelectClauseElementRaw> selectClause) |
OnTriggerMergeActionUpdate(ExprNode optionalMatchCond,
java.util.List<OnTriggerSetAssignment> assignments) |
OnTriggerMergeEntry(ExprNode optionalMatchCond) |
OnTriggerMergeMatched(boolean matchedUnmatched,
ExprNode optionalMatchCond,
java.util.List<OnTriggerMergeAction> actions) |
OnTriggerSetAssignment(ExprNode expression)
Ctor.
|
OnTriggerSplitStream(InsertIntoDesc insertInto,
SelectClauseSpecRaw selectClause,
OnTriggerSplitStreamFromClause fromClause,
ExprNode whereClause)
Ctor.
|
OrderByItem(ExprNode exprNode,
boolean ascending)
Ctor.
|
OutputLimitSpec(java.lang.Double rate,
java.lang.String variableForRate,
OutputLimitRateType rateType,
OutputLimitLimitType displayLimit,
ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> thenExpressions,
java.util.List<ExprNode> crontabAtSchedule,
ExprTimePeriod timePeriodExpr,
ExprTimePeriod afterTimePeriodExpr,
java.lang.Integer afterNumberOfEvents,
boolean andAfterTerminate,
ExprNode andAfterTerminateExpr,
java.util.List<OnTriggerSetAssignment> andAfterTerminateSetExpressions) |
PropertyEvalAtom(ExprNode splitterExpression,
java.lang.String optionalResultEventType,
java.lang.String optionalAsName,
SelectClauseSpecRaw optionalSelectClause,
ExprNode optionalWhereClause)
Ctor.
|
SelectClauseExprCompiledSpec(ExprNode selectExpression,
java.lang.String assignedName,
java.lang.String providedName,
boolean isEvents)
Ctor.
|
SelectClauseExprRawSpec(ExprNode selectExpression,
java.lang.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,
java.util.Set<java.lang.String> variableReferences,
RowLimitSpec rowLimitSpec,
java.lang.String[] eventTypeReferences,
java.lang.annotation.Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
java.lang.String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
UpdateDesc(java.lang.String optionalStreamName,
java.util.List<OnTriggerSetAssignment> assignments,
ExprNode optionalWhereClause)
Ctor.
|
Constructor and Description |
---|
ContextDetailConditionCrontab(java.util.List<ExprNode> crontab,
boolean immediate) |
CreateIndexItem(java.util.List<ExprNode> expressions,
java.lang.String type,
java.util.List<ExprNode> parameters) |
CreateIndexItem(java.util.List<ExprNode> expressions,
java.lang.String type,
java.util.List<ExprNode> parameters) |
FilterSpecRaw(java.lang.String eventTypeName,
java.util.List<ExprNode> filterExpressions,
PropertyEvalSpec optionalPropertyEvalSpec)
Ctor.
|
ForClauseItemSpec(java.lang.String keyword,
java.util.List<ExprNode> expressions) |
GroupByClauseElementCombinedExpr(java.util.List<ExprNode> expressions) |
MethodStreamSpec(java.lang.String optionalStreamName,
ViewSpec[] viewSpecs,
java.lang.String ident,
java.lang.String className,
java.lang.String methodName,
java.util.List<ExprNode> expressions,
java.lang.String eventTypeName)
Ctor.
|
NamedWindowConsumerStreamSpec(java.lang.String windowName,
java.lang.String optionalAsName,
ViewSpec[] viewSpecs,
java.util.List<ExprNode> filterExpressions,
StreamSpecOptions streamSpecOptions,
PropertyEvaluator optPropertyEvaluator)
Ctor.
|
ObjectSpec(java.lang.String namespace,
java.lang.String objectName,
java.util.List<ExprNode> objectParameters)
Constructor.
|
OutputLimitSpec(java.lang.Double rate,
java.lang.String variableForRate,
OutputLimitRateType rateType,
OutputLimitLimitType displayLimit,
ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> thenExpressions,
java.util.List<ExprNode> crontabAtSchedule,
ExprTimePeriod timePeriodExpr,
ExprTimePeriod afterTimePeriodExpr,
java.lang.Integer afterNumberOfEvents,
boolean andAfterTerminate,
ExprNode andAfterTerminateExpr,
java.util.List<OnTriggerSetAssignment> andAfterTerminateSetExpressions) |
PatternGuardSpec(java.lang.String namespace,
java.lang.String objectName,
java.util.List<ExprNode> objectParameters)
Constructor.
|
PatternObserverSpec(java.lang.String namespace,
java.lang.String objectName,
java.util.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,
java.util.Set<java.lang.String> variableReferences,
RowLimitSpec rowLimitSpec,
java.lang.String[] eventTypeReferences,
java.lang.annotation.Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
java.lang.String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
TableQueryStreamSpec(java.lang.String optionalStreamName,
ViewSpec[] viewSpecs,
StreamSpecOptions streamSpecOptions,
java.lang.String tableName,
java.util.List<ExprNode> filterExpressions) |
ViewSpec(java.lang.String namespace,
java.lang.String objectName,
java.util.List<ExprNode> viewParameters)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static java.util.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,
java.util.List<TableOnMergeAction> actions,
EngineImportService engineImportService,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
ExprNode |
TableColumnMethodPair.getAggregationNode() |
Modifier and Type | Method and Description |
---|---|
Pair<ExprNode,java.util.List<ExprChainedSpec>> |
TableServiceImpl.getTableNodeChainable(StreamTypeService streamTypeService,
java.util.List<ExprChainedSpec> chainSpec,
EngineImportService engineImportService) |
Pair<ExprNode,java.util.List<ExprChainedSpec>> |
TableService.getTableNodeChainable(StreamTypeService streamTypeService,
java.util.List<ExprChainedSpec> chainSpec,
EngineImportService engineImportService) |
Constructor and Description |
---|
TableColumnMethodPair(ExprEvaluator evaluator,
ExprForge[] forges,
int targetIndex,
ExprNode aggregationNode) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
ExprTableExprEvaluatorBase.exprNode |
Modifier and Type | Method and Description |
---|---|
static ExprTableExprEvaluatorBase |
ExprTableEvalStrategyFactory.getTableAccessEvalStrategy(ExprNode exprNode,
java.lang.String tableName,
java.lang.Integer streamNum,
TableMetadataColumnAggregation agg) |
Constructor and Description |
---|
ExprTableExprEvaluatorAccess(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName,
int streamNum,
java.lang.Class returnType,
AggregationAccessorSlotPair accessAccessorSlotPair,
EventType eventTypeColl) |
ExprTableExprEvaluatorBase(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName,
int streamNum,
java.lang.Class returnType) |
ExprTableExprEvaluatorMethod(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName,
int streamNum,
java.lang.Class returnType,
int methodNum) |
Modifier and Type | Method and Description |
---|---|
static void |
EPLValidationUtil.validateParametersTypePredefined(ExprNode[] expressions,
java.lang.String invocableName,
java.lang.String invocableCategory,
EPLExpressionParamType type) |
static void |
EPLValidationUtil.validateParameterType(java.lang.String invocableName,
java.lang.String invocableCategory,
boolean isFunction,
EPLExpressionParamType expectedTypeEnum,
java.lang.Class[] expectedTypeClasses,
java.lang.Class providedType,
int parameterNum,
ExprNode parameterExpression) |
Constructor and Description |
---|
FilterExprView(ExprNode exprNode,
ExprEvaluator exprEvaluator,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
OutputConditionExpressionFactory(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> assignments,
StatementContext statementContext,
ExprNode andWhenTerminatedExpr,
java.util.List<OnTriggerSetAssignment> afterTerminateAssignments,
boolean isStartConditionOnCreation) |
OutputConditionPolledExpressionFactory(ExprNode whenExpressionNode,
java.util.List<OnTriggerSetAssignment> assignments,
StatementContext statementContext)
Ctor.
|
Constructor and Description |
---|
OutputConditionCrontabFactory(java.util.List<ExprNode> scheduleSpecExpressionList,
StatementContext statementContext,
boolean isStartConditionOnCreation) |
OutputConditionPolledCrontabFactory(java.util.List<ExprNode> scheduleSpecExpressionList,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualDWViewFactoryImpl.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParameters) |
Modifier and Type | Method and Description |
---|---|
static InstanceManufacturerFactory |
InstanceManufacturerFactoryFactory.getManufacturer(java.lang.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 |
---|---|
java.util.List<ExprNode> |
FilterParamExprMap.getUnassignedExpressions()
Returns all expression nodes for which no filter parameter exists.
|
static java.util.List<ExprNode> |
FilterSpecCompiler.validateAllowSubquery(ExprNodeOrigin exprNodeOrigin,
java.util.List<ExprNode> exprNodes,
StreamTypeService streamTypeService,
StatementContext statementContext,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes)
Validates expression nodes and returns a list of validated nodes.
|
Modifier and Type | Method and Description |
---|---|
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableMultiStream(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableServiceToUse,
EngineImportService engineImportService,
EventBean[] events,
java.lang.annotation.Annotation[] annotations) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableServiceToUse,
EngineImportService engineImportService,
EventBean[] events,
java.lang.annotation.Annotation[] annotations) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableSingle(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
StatementContext statementContext,
int agentInstanceId) |
protected static FilterSpecParam |
FilterSpecCompilerMakeParamUtil.makeFilterParam(ExprNode constituent,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.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(java.util.List<ExprNode> validatedNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
StatementContext stmtContext,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack) |
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedFilterNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext) |
static FilterSpecCompiled |
FilterSpecCompiler.makeFilterSpec(EventType eventType,
java.lang.String eventTypeName,
java.util.List<ExprNode> filterExpessions,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
StatementContext statementContext,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack)
Factory method for compiling filter expressions into a filter specification
for use with filter service.
|
protected static java.util.List<FilterSpecParam>[] |
FilterSpecCompilerPlanner.planFilterParameters(java.util.List<ExprNode> validatedNodes,
FilterSpecCompilerArgs args) |
static java.util.List<ExprNode> |
FilterSpecCompiler.validateAllowSubquery(ExprNodeOrigin exprNodeOrigin,
java.util.List<ExprNode> exprNodes,
StreamTypeService streamTypeService,
StatementContext statementContext,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes)
Validates expression nodes and returns a list of validated nodes.
|
Constructor and Description |
---|
ExprNodeAdapterBase(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
EngineImportService engineImportService,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterBaseStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterBaseVariables(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterBaseWTableAccess(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
ExprNodeAdapterBase evalBase,
TableService tableService,
EngineImportService engineImportService,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterMultiStream(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterMultiStreamNoTLStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
java.lang.annotation.Annotation[] annotations) |
ExprNodeAdapterMultiStreamStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
java.lang.annotation.Annotation[] annotations) |
FilterSpecCompilerAdvIndexDesc(ExprNode[] indexExpressions,
ExprNode[] keyExpressions,
AdvancedIndexConfigContextPartition indexSpec,
java.lang.String indexType,
java.lang.String indexName) |
FilterSpecCompilerAdvIndexDesc(ExprNode[] indexExpressions,
ExprNode[] keyExpressions,
AdvancedIndexConfigContextPartition indexSpec,
java.lang.String indexType,
java.lang.String indexName) |
FilterSpecParamExprNode(FilterSpecLookupable lookupable,
FilterOperator filterOperator,
ExprNode exprNode,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.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,
java.lang.String tableName,
java.lang.String subpropName,
ExprAggregateNode aggregationExpression) |
void |
Instrumentation.qExprTableSubpropAccessor(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName,
ExprAggregateNode aggregationExpression) |
void |
InstrumentationDefault.qExprTableSubproperty(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName) |
void |
Instrumentation.qExprTableSubproperty(ExprNode exprNode,
java.lang.String tableName,
java.lang.String subpropName) |
void |
InstrumentationDefault.qExprTableTop(ExprNode exprNode,
java.lang.String tableName) |
void |
Instrumentation.qExprTableTop(ExprNode exprNode,
java.lang.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 java.util.List<ExprNode> |
EvalEveryDistinctFactoryNode.distinctExpressions |
protected java.util.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 |
---|---|
java.util.List<ExprNode> |
EvalEveryDistinctFactoryNode.getDistinctExpressions()
Returns distinct expressions.
|
java.util.List<ExprNode> |
EvalEveryDistinctFactoryNode.getExpressions()
Returns all expressions.
|
java.util.List<ExprNode> |
EvalFollowedByFactoryNode.getOptionalMaxExpressions() |
Modifier and Type | Method and Description |
---|---|
static java.lang.Object |
PatternExpressionUtil.evaluate(java.lang.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(java.util.List<ExprNode> distinctExpressions,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ExprNode expiryTimeExp,
EngineImportService engineImportService,
java.lang.String statementName) |
void |
EvalMatchUntilFactoryNode.setLowerBounds(ExprNode lowerBounds) |
void |
EvalMatchUntilFactoryNode.setSingleBound(ExprNode singleBound) |
void |
EvalMatchUntilFactoryNode.setUpperBounds(ExprNode upperBounds) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<java.lang.Object> |
PatternExpressionUtil.evaluate(java.lang.String objectName,
MatchedEventMap beginState,
java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
EvalFactoryNode |
PatternNodeFactoryImpl.makeEveryDistinctNode(java.util.List<ExprNode> expressions) |
EvalFactoryNode |
PatternNodeFactory.makeEveryDistinctNode(java.util.List<ExprNode> expressions) |
EvalFactoryNode |
PatternNodeFactoryImpl.makeFollowedByNode(java.util.List<ExprNode> maxExpressions,
boolean hasEngineWideMax) |
EvalFactoryNode |
PatternNodeFactory.makeFollowedByNode(java.util.List<ExprNode> maxExpressions,
boolean hasEngineWideMax) |
void |
EvalEveryDistinctFactoryNode.setDistinctExpressions(java.util.List<ExprNode> distinctExpressions,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ExprNode expiryTimeExp,
EngineImportService engineImportService,
java.lang.String statementName) |
void |
EvalFollowedByFactoryNode.setOptionalMaxExpressions(java.util.List<ExprNode> optionalMaxExpressions) |
Constructor and Description |
---|
EvalMatchUntilFactoryNode(ExprNode lowerBounds,
ExprNode upperBounds,
ExprNode singleBound) |
Constructor and Description |
---|
EvalEveryDistinctFactoryNode(java.util.List<ExprNode> expressions)
Ctor.
|
EvalFollowedByFactoryNode(java.util.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(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor) |
void |
TimerWithinGuardFactory.setGuardParameters(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor) |
void |
GuardFactory.setGuardParameters(java.util.List<ExprNode> guardParameters,
MatchedEventConvertor convertor)
Sets the guard object parameters.
|
void |
ExpressionGuardFactory.setGuardParameters(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
TimerIntervalObserverFactory.parameter
Parameters.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<ExprNode> |
TimerAtObserverFactory.parameters
Parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
TimerScheduleObserverFactory.setObserverParameters(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
TimerIntervalObserverFactory.setObserverParameters(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
TimerAtObserverFactory.setObserverParameters(java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext) |
void |
ObserverFactory.setObserverParameters(java.util.List<ExprNode> observerParameters,
MatchedEventConvertor convertor,
ExprValidationContext validationContext)
Sets the observer object parameters.
|
static void |
ObserverParameterUtil.validateNoNamedParameters(java.lang.String name,
java.util.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 |
---|---|
java.util.LinkedHashMap<java.lang.String,java.util.List<ExprNode>> |
PlugInAggregationMultiFunctionValidationContext.getNamedParameters()
Gets the named parameters as a list
|
Constructor and Description |
---|
PlugInAggregationMultiFunctionAgentContext(ExprNode[] childNodes,
ExprNode optionalFilterExpression) |
PlugInAggregationMultiFunctionAgentContext(ExprNode[] childNodes,
ExprNode optionalFilterExpression) |
PlugInAggregationMultiFunctionValidationContext(java.lang.String functionName,
EventType[] eventTypes,
ExprNode[] parameterExpressions,
java.lang.String engineURI,
java.lang.String statementName,
ExprValidationContext validationContext,
ConfigurationPlugInAggregationMultiFunction config,
TableMetadataColumnAggregation optionalTableColumnAccessed,
ExprNode[] allParameterExpressions) |
PlugInAggregationMultiFunctionValidationContext(java.lang.String functionName,
EventType[] eventTypes,
ExprNode[] parameterExpressions,
java.lang.String engineURI,
java.lang.String statementName,
ExprValidationContext validationContext,
ConfigurationPlugInAggregationMultiFunction config,
TableMetadataColumnAggregation optionalTableColumnAccessed,
ExprNode[] allParameterExpressions) |
Modifier and Type | Field and Description |
---|---|
protected java.util.HashMap<java.lang.String,Pair<ExprNode,ExprEvaluator>> |
EventRowRegexNFAViewFactory.variableDefinitions |
Modifier and Type | Method and Description |
---|---|
ExprNode |
RowRegexExprRepeatDesc.getLower() |
ExprNode[] |
RegexPartitionStateRepoGroupMeta.getPartitionExpressionNodes() |
ExprNode |
RowRegexExprRepeatDesc.getSingle() |
ExprNode |
RowRegexExprRepeatDesc.getUpper() |
Modifier and Type | Method and Description |
---|---|
protected static RegexNFAStrandResult |
EventRowRegexHelper.recursiveBuildStartStates(RowRegexExprNode parent,
java.util.Map<java.lang.String,Pair<ExprNode,ExprEvaluator>> variableDefinitions,
java.util.Map<java.lang.String,Pair<java.lang.Integer,java.lang.Boolean>> variableStreams,
boolean[] exprRequiresMultimatchState)
Build a list of start states from the parent node.
|
void |
EventRowRegexNFAViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParameters) |
Constructor and Description |
---|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
RowRegexExprRepeatDesc(ExprNode lower,
ExprNode upper,
ExprNode single) |
Constructor and Description |
---|
RegexNFAStateFilter(java.lang.String nodeNum,
java.lang.String variableName,
int streamNum,
boolean multiple,
Pair<ExprNode,ExprEvaluator> expression,
boolean exprRequiresMultimatchState)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
MinMaxTypeEnum.ComputerBigDecCoerce.codegen(boolean max,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode[] nodes,
SimpleNumberBigDecimalCoercer[] convertors) |
static CodegenExpression |
MinMaxTypeEnum.ComputerBigIntCoerce.codegen(boolean max,
CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode[] nodes,
SimpleNumberBigIntegerCoercer[] convertors) |
static CodegenExpression |
MinMaxTypeEnum.MinComputerDoubleCoerce.codegen(CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode[] nodes,
java.lang.Class returnType) |
static CodegenExpression |
MinMaxTypeEnum.MaxComputerDoubleCoerce.codegen(CodegenMethodScope codegenMethodScope,
ExprForgeCodegenSymbol exprSymbol,
CodegenClassScope codegenClassScope,
ExprNode[] nodes,
java.lang.Class returnType) |
Modifier and Type | Method and Description |
---|---|
static Pair<ExprNode,java.lang.String> |
StatementSelectionUtil.compileValidateStatementFilterExpr(EPServiceProviderSPI engine,
java.lang.String filterExpression) |
Modifier and Type | Method and Description |
---|---|
static boolean |
StatementSelectionUtil.evaluateStatement(ExprNode expression,
EPStatement stmt) |
static java.util.Comparator<java.lang.Object> |
CollectionUtil.getComparatorHashableMultiKeys(ExprNode[] sortCriteria,
boolean isSortUsingCollator,
boolean[] isDescendingValues) |
Modifier and Type | Method and Description |
---|---|
static ExprNode[] |
ViewFactorySupport.validate(java.lang.String viewName,
EventType eventType,
StatementContext statementContext,
java.util.List<ExprNode> expressions,
boolean allowConstantResult)
Validate the view parameter expressions and return the validated expression for later execution.
|
static ExprNode[] |
ViewFactorySupport.validate(java.lang.String viewName,
StatementContext statementContext,
java.util.List<ExprNode> expressions) |
static ExprNode |
ViewFactorySupport.validateExpr(java.lang.String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
Modifier and Type | Method and Description |
---|---|
static void |
ViewFactorySupport.assertReturnsNonConstant(java.lang.String viewName,
ExprNode expression,
int index)
Assert and throws an exception if the expression passed returns a non-constant value.
|
static java.lang.Object |
ViewFactorySupport.evaluateAssertNoProperties(java.lang.String viewName,
ExprNode expression,
int index,
ExprEvaluatorContext exprEvaluatorContext) |
static java.lang.Object |
ViewFactorySupport.validateAndEvaluate(java.lang.String viewName,
StatementContext statementContext,
ExprNode expression)
Validate the view parameter expression and evaluate the expression returning the result object.
|
static java.lang.Object |
ViewFactorySupport.validateAndEvaluateExpr(java.lang.String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
static ExprTimePeriodEvalDeltaConstFactory |
ViewFactoryTimePeriodHelper.validateAndEvaluateTimeDeltaFactory(java.lang.String viewName,
StatementContext statementContext,
ExprNode expression,
java.lang.String expectedMessage,
int expressionNumber) |
static ExprNode |
ViewFactorySupport.validateExpr(java.lang.String viewName,
StatementContext statementContext,
ExprNode expression,
StreamTypeService streamTypeService,
int expressionNumber) |
static void |
ViewFactorySupport.validateNoProperties(java.lang.String viewName,
ExprNode expression,
int index) |
static ExprEvaluator |
ViewFactorySupport.validateSizeParam(java.lang.String viewName,
StatementContext statementContext,
ExprNode sizeNode,
int expressionNumber) |
Modifier and Type | Method and Description |
---|---|
void |
ViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.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,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
Validate the view.
|
static ExprNode[] |
ViewFactorySupport.validate(java.lang.String viewName,
EventType eventType,
StatementContext statementContext,
java.util.List<ExprNode> expressions,
boolean allowConstantResult)
Validate the view parameter expressions and return the validated expression for later execution.
|
static ExprNode[] |
ViewFactorySupport.validate(java.lang.String viewName,
StatementContext statementContext,
java.util.List<ExprNode> expressions) |
static void |
ViewFactorySupport.validateNoParameters(java.lang.String viewName,
java.util.List<ExprNode> expressionParameters) |
static ExprEvaluator |
ViewFactorySupport.validateSizeSingleParam(java.lang.String viewName,
ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
SortWindowViewFactory.sortCriteriaExpressions
The sort-by expressions.
|
protected ExprNode[] |
RankWindowViewFactory.sortCriteriaExpressions
The sort-by expressions.
|
protected ExprNode |
TimeToLiveViewFactory.timestampExpression
The timestamp expression.
|
protected ExprNode |
TimeOrderViewFactory.timestampExpression
The timestamp expression.
|
protected ExprNode[] |
RankWindowViewFactory.uniqueCriteriaExpressions
The unique-by expressions.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
SortWindowViewFactory.getSortCriteriaExpressions() |
protected ExprNode[] |
SortWindowView.getSortCriteriaExpressions()
Returns the field names supplying the values to sort by.
|
ExprNode[] |
RankWindowViewFactory.getSortCriteriaExpressions() |
ExprNode |
TimeToLiveViewFactory.getTimestampExpression() |
ExprNode |
TimeOrderView.getTimestampExpression()
Returns the timestamp property name.
|
ExprNode[] |
RankWindowViewFactory.getUniqueCriteriaExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
TimeToLiveViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
TimeOrderViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
SortWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParams) |
void |
RankWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParams) |
Constructor and Description |
---|
TimeOrderView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ViewFactory viewFactory,
ExprNode timestampExpr,
ExprEvaluator timestampEvaluator,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
IStreamSortRankRandomAccess optionalSortedRandomAccess) |
Modifier and Type | Method and Description |
---|---|
void |
UnionViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParameters) |
void |
PriorEventViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
NoopViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParameters) |
void |
IntersectViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> viewParameters) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode |
RegressionLinestViewFactory.expressionX |
protected ExprNode |
CorrelationViewFactory.expressionX |
protected ExprNode |
RegressionLinestViewFactory.expressionY |
protected ExprNode |
CorrelationViewFactory.expressionY |
protected ExprNode |
UnivariateStatisticsViewFactory.fieldExpression
Property name of data field.
|
protected ExprNode |
WeightedAverageViewFactory.fieldNameWeight |
protected ExprNode |
WeightedAverageViewFactory.fieldNameX |
Modifier and Type | Method and Description |
---|---|
ExprNode |
BaseBivariateStatisticsView.getExpressionX()
Returns the expression supplying X data points.
|
ExprNode |
BaseBivariateStatisticsView.getExpressionY()
Returns the expression supplying Y data points.
|
ExprNode |
UnivariateStatisticsView.getFieldExpression()
Returns field name of the field to report statistics on.
|
ExprNode |
WeightedAverageView.getFieldNameWeight()
Returns the expression supplying the weight values.
|
ExprNode |
WeightedAverageView.getFieldNameX()
Returns the expression supplying the X values.
|
Modifier and Type | Method and Description |
---|---|
static StatViewAdditionalProps |
StatViewAdditionalProps.make(ExprNode[] validated,
int startIndex,
EventType parentEventType,
EngineImportService engineImportService,
java.lang.String statementName) |
void |
UnivariateStatisticsViewFactory.setFieldExpression(ExprNode fieldExpression) |
void |
WeightedAverageViewFactory.setFieldNameWeight(ExprNode fieldNameWeight) |
void |
WeightedAverageViewFactory.setFieldNameX(ExprNode fieldNameX) |
Modifier and Type | Method and Description |
---|---|
void |
WeightedAverageViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
UnivariateStatisticsViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
RegressionLinestViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
CorrelationViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
Constructor and Description |
---|
BaseBivariateStatisticsView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode expressionX,
ExprEvaluator expressionXEval,
ExprNode expressionY,
ExprEvaluator expressionYEval,
EventType eventType,
StatViewAdditionalProps additionalProps)
Constructor requires the name of the two fields to use in the parent view to compute the statistics.
|
CorrelationView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xExpression,
ExprEvaluator xExpressionEval,
ExprNode yExpression,
ExprEvaluator yExpressionEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprEvaluator xEval,
ExprNode yFieldName,
ExprEvaluator yEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
Modifier and Type | Field and Description |
---|---|
protected ExprNode[] |
UniqueByPropertyViewFactory.criteriaExpressions
Property name to evaluate unique values.
|
protected ExprNode[] |
GroupByViewFactory.criteriaExpressions
List of criteria expressions.
|
protected ExprNode[] |
FirstUniqueByPropertyViewFactory.criteriaExpressions
Property name to evaluate unique values.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<ExprNode> |
UniqueByPropertyViewFactory.viewParameters
View parameters.
|
protected java.util.List<ExprNode> |
GroupByViewFactory.viewParameters
View parameters.
|
protected java.util.List<ExprNode> |
FirstUniqueByPropertyViewFactory.viewParameters
View parameters.
|
Modifier and Type | Method and Description |
---|---|
ExprNode[] |
UniqueByPropertyViewFactory.getCriteriaExpressions() |
ExprNode[] |
UniqueByPropertyView.getCriteriaExpressions()
Returns the name of the field supplying the unique value to keep the most recent record for.
|
ExprNode[] |
MergeViewFactory.getCriteriaExpressions() |
ExprNode[] |
GroupByViewReclaimAged.getCriteriaExpressions()
Returns the field name that provides the key valie by which to group by.
|
ExprNode[] |
GroupByViewFactoryMarker.getCriteriaExpressions() |
ExprNode[] |
GroupByViewFactory.getCriteriaExpressions()
Returns the names of fields to group by
|
ExprNode[] |
FirstUniqueByPropertyViewFactory.getCriteriaExpressions() |
ExprNode[] |
MergeViewMarker.getGroupFieldNames() |
ExprNode[] |
MergeView.getGroupFieldNames()
Returns the field name that contains the values to group by.
|
ExprNode[] |
FirstUniqueByPropertyView.getUniqueCriteria()
Returns the expressions supplying the unique value to keep the most recent record for.
|
Modifier and Type | Method and Description |
---|---|
void |
UniqueByPropertyViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
SizeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
MergeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
LastElementViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
GroupByViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
FirstUniqueByPropertyViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
FirstElementViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
Constructor and Description |
---|
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,
java.util.List<ExprNode> expressionParameters) |
void |
TimeLengthBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
TimeBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
TimeAccumViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
LengthWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
LengthBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
KeepAllViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
FirstTimeViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
FirstLengthWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
ExternallyTimedWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
ExternallyTimedBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
ExpressionWindowViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
void |
ExpressionBatchViewFactory.setViewParameters(ViewFactoryContext viewFactoryContext,
java.util.List<ExprNode> expressionParameters) |
Constructor and Description |
---|
ExternallyTimedBatchView(ExternallyTimedBatchViewFactory factory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
java.lang.Long optionalReferencePoint,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|
ExternallyTimedWindowView(ExternallyTimedWindowViewFactory externallyTimedWindowViewFactory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|