All Methods Static Methods Concrete Methods
Modifier and Type |
Method and Description |
static void |
acceptChain(ExprNodeVisitor visitor,
List<ExprChainedSpec> chainSpec) |
static void |
acceptChain(ExprNodeVisitorWithParent visitor,
List<ExprChainedSpec> chainSpec) |
static void |
acceptChain(ExprNodeVisitorWithParent visitor,
List<ExprChainedSpec> chainSpec,
ExprNode parent) |
static ExprNode[] |
addExpression(ExprNode[] expressions,
ExprNode expression) |
static void |
addNonAggregatedProps(ExprNode exprNode,
ExprNodePropOrStreamSet set,
EventType[] types,
ContextPropertyRegistry contextPropertyRegistry) |
static boolean |
applyFilterExpression(ExprEvaluator filter,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Apply a filter expression returning a pass indicator.
|
static EventBean[] |
applyFilterExpression(ExprEvaluator filter,
EventBean streamZeroEvent,
EventBean[] streamOneEvents,
ExprEvaluatorContext exprEvaluatorContext)
Apply a filter expression.
|
static void |
applyFilterExpressionIterable(Iterator<EventBean> iterator,
ExprEvaluator filterExpression,
ExprEvaluatorContext exprEvaluatorContext,
Collection<EventBean> eventsInWindow) |
static void |
applyFilterExpressionsIterable(Iterable<EventBean> iterable,
List<ExprNode> filterExpressions,
ExprEvaluatorContext exprEvaluatorContext,
Collection<EventBean> eventsInWindow) |
static Pair<String,ExprNode> |
checkGetAssignmentToProp(ExprNode node) |
static Pair<String,ExprNode> |
checkGetAssignmentToVariableOrProp(ExprNode node) |
static void |
checkValidated(ExprForge forge) |
static IllegalStateException |
checkValidatedException() |
static List<ExprNode> |
collectChainParameters(List<ExprChainedSpec> chainSpec) |
static ExprAndNode |
connectExpressionsByLogicalAnd(Collection<ExprNode> nodes) |
static ExprNode |
connectExpressionsByLogicalAnd(List<ExprNode> nodes,
ExprNode optionalAdditionalFilter) |
static ExprNode |
connectExpressionsByLogicalAndWhenNeeded(Collection<ExprNode> nodes) |
static ScheduleSpec |
crontabScheduleBuild(ExprEvaluator[] scheduleSpecEvaluators,
ExprEvaluatorContext context) |
static ExprEvaluator[] |
crontabScheduleValidate(ExprNodeOrigin origin,
List<ExprNode> scheduleSpecExpressionList,
StatementContext context,
boolean allowBindingConsumption) |
static boolean |
deepEquals(ExprNode[] one,
ExprNode[] two,
boolean ignoreStreamPrefix)
Compares two expression nodes via deep comparison, considering all
child nodes of either side.
|
static boolean |
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 |
deepEquals(List<ExprNode> one,
List<ExprNode> two) |
static boolean |
deepEqualsIgnoreDupAndOrder(ExprNode[] setOne,
ExprNode[] setTwo) |
static boolean |
deepEqualsIsSubset(ExprNode[] subset,
ExprNode[] superset) |
static Object[] |
evaluateExpressions(ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
evaluateValidationTimeNoStreams(ExprEvaluator evaluator,
ExprEvaluatorContext context,
String expressionName) |
static List<Pair<ExprNode,ExprNode>> |
findExpression(ExprNode selectExpression,
ExprNode searchExpression) |
static ExprNodePropOrStreamSet |
getAggregatedProperties(List<ExprAggregateNode> aggregateNodes) |
static Map<ExprDeclaredNode,List<ExprDeclaredNode>> |
getDeclaredExpressionCallHierarchy(ExprDeclaredNode[] declaredExpressions) |
static ExprEvaluator[] |
getEvaluatorsMayCompile(ExprForge[] forges,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
getEvaluatorsMayCompile(ExprNode[] exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
getEvaluatorsMayCompile(List<ExprNode> exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
getEvaluatorsNoCompile(ExprForge[] forges) |
static ExprEvaluator[] |
getEvaluatorsNoCompile(ExprNode[] exprNodes) |
static ExprEvaluator[] |
getEvaluatorsNoCompile(List<ExprNode> childNodes) |
static List<Pair<Integer,String>> |
getExpressionProperties(ExprNode exprNode,
boolean visitAggregateNodes)
Walk expression returning properties used.
|
static ExprIdentNode |
getExprIdentNode(EventType[] typesPerStream,
int streamId,
String property) |
static Class[] |
getExprResultTypes(ExprNode[] nodes) |
static Class[] |
getExprResultTypes(List<ExprNode> expressions) |
static ExprValidationContext |
getExprValidationContextStatementOnly(StatementContext statementContext) |
static ExprForge[] |
getForges(ExprNode[] exprNodes) |
static ExprNodePropOrStreamSet |
getGroupByPropertiesValidateHasOne(ExprNode[] groupByNodes) |
static String[] |
getIdentResolvedPropertyNames(ExprNode[] nodes) |
static Set<Integer> |
getIdentStreamNumbers(ExprNode child) |
static Map<String,ExprNamedParameterNode> |
getNamedExpressionsHandleDups(List<ExprNode> parameters) |
static ExprNodePropOrStreamSet |
getNonAggregatedProps(EventType[] types,
List<ExprNode> exprNodes,
ContextPropertyRegistry contextPropertyRegistry) |
static Set<String> |
getPropertyNamesIfAllProps(ExprNode[] expressions) |
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(List<ExprNode> exprNodes) |
static boolean |
isAllConstants(List<ExprNode> parameters) |
static boolean |
isConstantValueExpr(ExprNode exprNode) |
static String |
isMinimalExpression(ExprNode expression)
Check if the expression is minimal: does not have a subselect, aggregation and does not need view resources
|
static ExprEvaluator |
makeUnderlyingEvaluator(int streamNum,
Class resultType,
TableMetadata tableMetadata) |
static ExprNodeUtility.MappedPropertyParseResult |
parseMappedProperty(String property)
Parse the mapped property into classname, method and string argument.
|
static String |
printEvaluators(ExprEvaluator[] evaluators) |
static void |
replaceChainChildNode(ExprNode nodeToReplace,
ExprNode newNode,
List<ExprChainedSpec> chainSpec) |
static void |
replaceChildNode(ExprNode parentNode,
ExprNode nodeToReplace,
ExprNode newNode) |
static ExprNodeUtilMethodDesc |
resolveMethodAllowWildcardAndStream(String className,
Class optionalClass,
String methodName,
List<ExprNode> parameters,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
int statementId,
boolean allowWildcard,
EventType wildcardType,
ExprNodeUtilResolveExceptionHandler exceptionHandler,
String functionName,
TableService tableService,
String engineURI) |
static ExprNode[] |
toArray(Collection<ExprNode> expressions) |
static ExprDeclaredNode[] |
toArray(List<ExprDeclaredNode> declaredNodes) |
static void |
toExpressionString(ExprNode node,
StringWriter buffer) |
static void |
toExpressionString(List<ExprChainedSpec> chainSpec,
StringWriter buffer,
boolean prefixDot,
String functionName) |
static void |
toExpressionStringIncludeParen(List<ExprNode> parameters,
StringWriter buffer) |
static String[] |
toExpressionStringMinPrecedenceAsArray(ExprNode[] nodes) |
static String |
toExpressionStringMinPrecedenceAsList(ExprNode[] nodes) |
static void |
toExpressionStringMinPrecedenceAsList(ExprNode[] nodes,
StringWriter writer) |
static String |
toExpressionStringMinPrecedenceSafe(ExprNode node) |
static void |
toExpressionStringParameterList(ExprNode[] childNodes,
StringWriter buffer) |
static void |
toExpressionStringParameterList(List<ExprNode> parameters,
StringWriter buffer) |
static void |
toExpressionStringParams(StringWriter writer,
ExprNode[] params) |
static String[] |
toExpressionStringsMinPrecedence(ExprNode[] expressions) |
static void |
toExpressionStringWFunctionName(String functionName,
ExprNode[] childNodes,
StringWriter writer) |
static void |
validate(ExprNodeOrigin origin,
List<ExprChainedSpec> chainSpec,
ExprValidationContext validationContext) |
static QueryGraph |
validateFilterGetQueryGraphSafe(ExprNode filterExpression,
StatementContext statementContext,
StreamTypeServiceImpl typeService) |
static void |
validateFilterWQueryGraphSafe(QueryGraph queryGraph,
ExprNode filterExpression,
StatementContext statementContext,
StreamTypeServiceImpl typeService) |
static void |
validateNamed(Map<String,ExprNamedParameterNode> namedExpressions,
String[] namedParameters) |
static boolean |
validateNamedExpectType(ExprNamedParameterNode namedParameterNode,
Class[] expectedTypes) |
static void |
validateNoSpecialsGroupByExpressions(ExprNode[] groupByNodes) |
static void |
validatePlainExpression(ExprNodeOrigin origin,
ExprNode expression) |
static void |
validatePlainExpression(ExprNodeOrigin origin,
ExprNode[] expressions) |
static ExprNode |
validateSimpleGetSubtree(ExprNodeOrigin origin,
ExprNode expression,
StatementContext statementContext,
EventType optionalEventType,
boolean allowBindingConsumption) |