com.espertech.esper.epl.util

Class ExprNodeUtilityRich

java.lang.Object

com.espertech.esper.epl.util.ExprNodeUtilityRich

public class ExprNodeUtilityRich
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExprNodeUtilityRich.MappedPropertyParseResult Encapsulates the parse result parsing a mapped property as a class and method name with args.

Field Summary

Fields

Modifier and Type	Field and Description
static ExprDeclaredNode[]	EMPTY_DECLARED_ARR
static ExpressionScriptProvided[]	EMPTY_SCRIPTS

Constructor Summary

Constructors

Constructor and Description
ExprNodeUtilityRich()

Method Summary

Modifier and Type	Method and Description
static void	acceptChain(ExprNodeVisitor visitor, java.util.List<ExprChainedSpec> chainSpec)
static void	acceptChain(ExprNodeVisitorWithParent visitor, java.util.List<ExprChainedSpec> chainSpec)
static void	acceptChain(ExprNodeVisitorWithParent visitor, java.util.List<ExprChainedSpec> chainSpec, ExprNode parent)
static void	addNonAggregatedProps(ExprNode exprNode, ExprNodePropOrStreamSet set, EventType[] types, ContextPropertyRegistry contextPropertyRegistry)
static Pair<java.lang.String,ExprNode>	checkGetAssignmentToProp(ExprNode node)
static Pair<java.lang.String,ExprNode>	checkGetAssignmentToVariableOrProp(ExprNode node)
static java.util.List<ExprNode>	collectChainParameters(java.util.List<ExprChainedSpec> chainSpec)
static ExprAndNode	connectExpressionsByLogicalAnd(java.util.Collection<ExprNode> nodes)
static ExprNode	connectExpressionsByLogicalAnd(java.util.List<ExprNode> nodes, ExprNode optionalAdditionalFilter)
static ExprNode	connectExpressionsByLogicalAndWhenNeeded(java.util.Collection<ExprNode> nodes)
static ExprNodePropOrStreamSet	getAggregatedProperties(java.util.List<ExprAggregateNode> aggregateNodes)
static java.util.Map<ExprDeclaredNode,java.util.List<ExprDeclaredNode>>	getDeclaredExpressionCallHierarchy(ExprDeclaredNode[] declaredExpressions)
static ExprEvaluator	getEvaluatorMayCompileWMultiValue(ExprForge[] forges, EngineImportService engineImportService, java.lang.Class requestor, boolean isFireAndForget, java.lang.String statementName)
static ExprEvaluator	getEvaluatorMultiValue(ExprEvaluator[] evaluators)
static ExprEvaluator[]	getEvaluatorsMayCompile(ExprForge[] forges, EngineImportService engineImportService, java.lang.Class requestor, boolean isFireAndForget, java.lang.String statementName)
static ExprEvaluator[]	getEvaluatorsMayCompile(ExprNode[] exprNodes, EngineImportService engineImportService, java.lang.Class requestor, boolean isFireAndForget, java.lang.String statementName)
static ExprEvaluator[]	getEvaluatorsMayCompile(java.util.List<ExprNode> exprNodes, EngineImportService engineImportService, java.lang.Class requestor, boolean isFireAndForget, java.lang.String statementName)
static ExprEvaluator[]	getEvaluatorsMayCompileWMultiValue(ExprForge[][] forges, EngineImportService engineImportService, java.lang.Class requestor, boolean isFireAndForget, java.lang.String statementName)
static java.util.List<Pair<java.lang.Integer,java.lang.String>>	getExpressionProperties(ExprNode exprNode, boolean visitAggregateNodes) Walk expression returning properties used.
static ExprNodePropOrStreamSet	getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes)
static java.util.Set<java.lang.Integer>	getIdentStreamNumbers(ExprNode child)
static java.util.Map<java.lang.String,ExprNamedParameterNode>	getNamedExpressionsHandleDups(java.util.List<ExprNode> parameters)
static ExprNodePropOrStreamSet	getNonAggregatedProps(EventType[] types, java.util.List<ExprNode> exprNodes, ContextPropertyRegistry contextPropertyRegistry)
static java.lang.String	getSubqueryInfoText(int subqueryNum, ExprSubselectNode subselect)
static ExprNode	getValidatedAssignment(OnTriggerSetAssignment assignment, ExprValidationContext validationContext)
static void	getValidatedSubtree(ExprNodeOrigin origin, ExprNode[][] exprNode, ExprValidationContext validationContext)
static void	getValidatedSubtree(ExprNodeOrigin origin, ExprNode[] exprNode, ExprValidationContext validationContext)
static ExprNode	getValidatedSubtree(ExprNodeOrigin origin, ExprNode exprNode, ExprValidationContext validationContext) Validates the expression node subtree that has this node as root.
static boolean	hasRemoveStreamForAggregations(ExprNode child, StreamTypeService streamTypeService, boolean unidirectionalJoin) Returns true if all properties within the expression are witin data window'd streams.
static boolean	hasStreamSelect(java.util.List<ExprNode> exprNodes)
static boolean	isAllConstants(java.util.List<ExprNode> parameters)
static java.lang.String	isMinimalExpression(ExprNode expression) Check if the expression is minimal: does not have a subselect, aggregation and does not need view resources
static ExprForge	makeUnderlyingForge(int streamNum, java.lang.Class resultType, TableMetadata tableMetadata)
static ExprNodeUtilityRich.MappedPropertyParseResult	parseMappedProperty(java.lang.String property) Parse the mapped property into classname, method and string argument.
static void	replaceChainChildNode(ExprNode nodeToReplace, ExprNode newNode, java.util.List<ExprChainedSpec> chainSpec)
static ExprNodeUtilMethodDesc	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)
static ExprDeclaredNode[]	toArray(java.util.List<ExprDeclaredNode> declaredNodes)
static void	toExpressionString(java.util.List<ExprChainedSpec> chainSpec, java.io.StringWriter buffer, boolean prefixDot, java.lang.String functionName)
static void	validate(ExprNodeOrigin origin, java.util.List<ExprChainedSpec> chainSpec, ExprValidationContext validationContext)
static void	validateNamed(java.util.Map<java.lang.String,ExprNamedParameterNode> namedExpressions, java.lang.String[] namedParameters)
static boolean	validateNamedExpectType(ExprNamedParameterNode namedParameterNode, java.lang.Class[] expectedTypes)
static void	validateNoSpecialsGroupByExpressions(ExprNode[] groupByNodes)
static void	validatePlainExpression(ExprNodeOrigin origin, ExprNode expression)
static void	validatePlainExpression(ExprNodeOrigin origin, ExprNode[] expressions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY_DECLARED_ARR

public static final ExprDeclaredNode[] EMPTY_DECLARED_ARR

EMPTY_SCRIPTS

public static final ExpressionScriptProvided[] EMPTY_SCRIPTS

Constructor Detail

ExprNodeUtilityRich

public ExprNodeUtilityRich()

Method Detail

getDeclaredExpressionCallHierarchy

public static java.util.Map<ExprDeclaredNode,java.util.List<ExprDeclaredNode>> getDeclaredExpressionCallHierarchy(ExprDeclaredNode[] declaredExpressions)

checkGetAssignmentToProp

public static Pair<java.lang.String,ExprNode> checkGetAssignmentToProp(ExprNode node)

checkGetAssignmentToVariableOrProp

public static Pair<java.lang.String,ExprNode> checkGetAssignmentToVariableOrProp(ExprNode node)
                                                                          throws ExprValidationException

Throws:

ExprValidationException

connectExpressionsByLogicalAnd

public static ExprNode connectExpressionsByLogicalAnd(java.util.List<ExprNode> nodes,
                                                      ExprNode optionalAdditionalFilter)

connectExpressionsByLogicalAnd

public static ExprAndNode connectExpressionsByLogicalAnd(java.util.Collection<ExprNode> nodes)

connectExpressionsByLogicalAndWhenNeeded

public static ExprNode connectExpressionsByLogicalAndWhenNeeded(java.util.Collection<ExprNode> nodes)

getExpressionProperties

public static java.util.List<Pair<java.lang.Integer,java.lang.String>> getExpressionProperties(ExprNode exprNode,
                                                                                               boolean visitAggregateNodes)

Walk expression returning properties used.

Parameters:

exprNode - to walk

visitAggregateNodes - true to visit aggregation nodes

Returns:

list of props

getValidatedSubtree

public static ExprNode getValidatedSubtree(ExprNodeOrigin origin,
                                           ExprNode exprNode,
                                           ExprValidationContext validationContext)
                                    throws ExprValidationException

Validates the expression node subtree that has this node as root. Some of the nodes of the tree, including the root, might be replaced in the process.

Parameters:

origin - validate origin

exprNode - node

validationContext - context

Returns:

the root node of the validated subtree, possibly different than the root node of the unvalidated subtree

Throws:

ExprValidationException - when the validation fails

getSubqueryInfoText

public static java.lang.String getSubqueryInfoText(int subqueryNum,
                                                   ExprSubselectNode subselect)

getValidatedSubtree

public static void getValidatedSubtree(ExprNodeOrigin origin,
                                       ExprNode[] exprNode,
                                       ExprValidationContext validationContext)
                                throws ExprValidationException

Throws:

ExprValidationException

getValidatedSubtree

public static void getValidatedSubtree(ExprNodeOrigin origin,
                                       ExprNode[][] exprNode,
                                       ExprValidationContext validationContext)
                                throws ExprValidationException

Throws:

ExprValidationException

getValidatedAssignment

public static ExprNode getValidatedAssignment(OnTriggerSetAssignment assignment,
                                              ExprValidationContext validationContext)
                                       throws ExprValidationException

Throws:

ExprValidationException

parseMappedProperty

public static ExprNodeUtilityRich.MappedPropertyParseResult parseMappedProperty(java.lang.String property)

Parse the mapped property into classname, method and string argument. Mind this has been parsed already and is a valid mapped property.

Parameters:

property - is the string property to be passed as a static method invocation

Returns:

descriptor object

isAllConstants

public static boolean isAllConstants(java.util.List<ExprNode> parameters)

resolveMethodAllowWildcardAndStream

public static ExprNodeUtilMethodDesc 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)
                                                                  throws ExprValidationException

Throws:

ExprValidationException

validatePlainExpression

public static void validatePlainExpression(ExprNodeOrigin origin,
                                           ExprNode expression)
                                    throws ExprValidationException

Throws:

ExprValidationException

validatePlainExpression

public static void validatePlainExpression(ExprNodeOrigin origin,
                                           ExprNode[] expressions)
                                    throws ExprValidationException

Throws:

ExprValidationException

makeUnderlyingForge

public static ExprForge makeUnderlyingForge(int streamNum,
                                            java.lang.Class resultType,
                                            TableMetadata tableMetadata)

hasStreamSelect

public static boolean hasStreamSelect(java.util.List<ExprNode> exprNodes)

validateNoSpecialsGroupByExpressions

public static void validateNoSpecialsGroupByExpressions(ExprNode[] groupByNodes)
                                                 throws ExprValidationException

Throws:

ExprValidationException

getNamedExpressionsHandleDups

public static java.util.Map<java.lang.String,ExprNamedParameterNode> getNamedExpressionsHandleDups(java.util.List<ExprNode> parameters)
                                                                                            throws ExprValidationException

Throws:

ExprValidationException

validateNamed

public static void validateNamed(java.util.Map<java.lang.String,ExprNamedParameterNode> namedExpressions,
                                 java.lang.String[] namedParameters)
                          throws ExprValidationException

Throws:

ExprValidationException

validateNamedExpectType

public static boolean validateNamedExpectType(ExprNamedParameterNode namedParameterNode,
                                              java.lang.Class[] expectedTypes)
                                       throws ExprValidationException

Throws:

ExprValidationException

acceptChain

public static void acceptChain(ExprNodeVisitor visitor,
                               java.util.List<ExprChainedSpec> chainSpec)

acceptChain

public static void acceptChain(ExprNodeVisitorWithParent visitor,
                               java.util.List<ExprChainedSpec> chainSpec)

acceptChain

public static void acceptChain(ExprNodeVisitorWithParent visitor,
                               java.util.List<ExprChainedSpec> chainSpec,
                               ExprNode parent)

replaceChainChildNode

public static void replaceChainChildNode(ExprNode nodeToReplace,
                                         ExprNode newNode,
                                         java.util.List<ExprChainedSpec> chainSpec)

getNonAggregatedProps

public static ExprNodePropOrStreamSet getNonAggregatedProps(EventType[] types,
                                                            java.util.List<ExprNode> exprNodes,
                                                            ContextPropertyRegistry contextPropertyRegistry)

addNonAggregatedProps

public static void addNonAggregatedProps(ExprNode exprNode,
                                         ExprNodePropOrStreamSet set,
                                         EventType[] types,
                                         ContextPropertyRegistry contextPropertyRegistry)

getAggregatedProperties

public static ExprNodePropOrStreamSet getAggregatedProperties(java.util.List<ExprAggregateNode> aggregateNodes)

getEvaluatorsMayCompile

public static ExprEvaluator[] getEvaluatorsMayCompile(ExprNode[] exprNodes,
                                                      EngineImportService engineImportService,
                                                      java.lang.Class requestor,
                                                      boolean isFireAndForget,
                                                      java.lang.String statementName)

getEvaluatorsMayCompile

public static ExprEvaluator[] getEvaluatorsMayCompile(java.util.List<ExprNode> exprNodes,
                                                      EngineImportService engineImportService,
                                                      java.lang.Class requestor,
                                                      boolean isFireAndForget,
                                                      java.lang.String statementName)

getEvaluatorsMayCompile

public static ExprEvaluator[] getEvaluatorsMayCompile(ExprForge[] forges,
                                                      EngineImportService engineImportService,
                                                      java.lang.Class requestor,
                                                      boolean isFireAndForget,
                                                      java.lang.String statementName)

getEvaluatorsMayCompileWMultiValue

public static ExprEvaluator[] getEvaluatorsMayCompileWMultiValue(ExprForge[][] forges,
                                                                 EngineImportService engineImportService,
                                                                 java.lang.Class requestor,
                                                                 boolean isFireAndForget,
                                                                 java.lang.String statementName)

getEvaluatorMayCompileWMultiValue

public static ExprEvaluator getEvaluatorMayCompileWMultiValue(ExprForge[] forges,
                                                              EngineImportService engineImportService,
                                                              java.lang.Class requestor,
                                                              boolean isFireAndForget,
                                                              java.lang.String statementName)

getEvaluatorMultiValue

public static ExprEvaluator getEvaluatorMultiValue(ExprEvaluator[] evaluators)

getIdentStreamNumbers

public static java.util.Set<java.lang.Integer> getIdentStreamNumbers(ExprNode child)

hasRemoveStreamForAggregations

public static boolean hasRemoveStreamForAggregations(ExprNode child,
                                                     StreamTypeService streamTypeService,
                                                     boolean unidirectionalJoin)

Returns true if all properties within the expression are witin data window'd streams.

Parameters:

child - expression to interrogate

streamTypeService - streams

unidirectionalJoin - indicator unidirection join

Returns:

indicator

isMinimalExpression

public static java.lang.String isMinimalExpression(ExprNode expression)

Check if the expression is minimal: does not have a subselect, aggregation and does not need view resources

Parameters:

expression - to inspect

Returns:

null if minimal, otherwise name of offending sub-expression

toExpressionString

public static void toExpressionString(java.util.List<ExprChainedSpec> chainSpec,
                                      java.io.StringWriter buffer,
                                      boolean prefixDot,
                                      java.lang.String functionName)

validate

public static void validate(ExprNodeOrigin origin,
                            java.util.List<ExprChainedSpec> chainSpec,
                            ExprValidationContext validationContext)
                     throws ExprValidationException

Throws:

ExprValidationException

collectChainParameters

public static java.util.List<ExprNode> collectChainParameters(java.util.List<ExprChainedSpec> chainSpec)

toArray

public static ExprDeclaredNode[] toArray(java.util.List<ExprDeclaredNode> declaredNodes)

getGroupByPropertiesValidateHasOne

public static ExprNodePropOrStreamSet getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes)
                                                                  throws ExprValidationException

Throws:

ExprValidationException