Package com.espertech.esper.epl.expression

Examples of com.espertech.esper.epl.expression.ExprNode

273
274
275
276
277
278
279
280
281
282
283
            RowRegexExprNodeAtom atom = (RowRegexExprNodeAtom) node;

            // assign stream number for single-variables for most direct expression eval; multiple-variable gets -1
            int streamNum = variableStreams.get(atom.getTag()).getFirst();
            boolean multiple = variableStreams.get(atom.getTag()).getSecond();
            ExprNode expressionDef = variableDefinitions.get(atom.getTag());

            RegexNFAStateBase nextState;
            if ((atom.getType() == RegexNFATypeEnum.ZERO_TO_MANY) || (atom.getType() == RegexNFATypeEnum.ZERO_TO_MANY_RELUCTANT))
            {
                nextState = new RegexNFAStateZeroToMany(toString(nodeNumStack), atom.getTag(), streamNum, multiple, atom.getType().isGreedy(), expressionDef);
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
  {
    List<ExprNode> childNodes = node.getChildNodes();

    for (ListIterator<ExprNode> itor = childNodes.listIterator(); itor.hasNext(); )
    {
      ExprNode childNode = itor.next();
      if(isColumnNameNode(childNode, name))
      {
        itor.set(fullExpr);
      }
      else
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
  {
    List<ExprNode> childNodes = node.getChildNodes();

    for (ListIterator<ExprNode> itor = childNodes.listIterator(); itor.hasNext(); )
    {
      ExprNode childNode = itor.next();
      if(isColumnNameNode(childNode, name))
      {
        itor.set(fullExpr);
      }
      else
View Full Code Here
298
299
300
301
302
303
304
305
        return raw.getStreamSpecs().get(0).getViewSpecs().get(0).getObjectParameters().get(0);
    }

    public Expression compileExpressionToSODA(String expression) throws EPException
    {
        ExprNode node = compileExpression(expression);
        return StatementSpecMapper.unmap(node);
    }
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
67
        {
            // Evaluate assignment expression
            StreamTypeService typeService = new StreamTypeServiceImpl(new EventType[0], new String[0], new boolean[0], services.getEngineURI(), false);
            ExprEvaluatorContextStatement evaluatorContextStmt = new ExprEvaluatorContextStatement(statementContext);
            ExprValidationContext validationContext = new ExprValidationContext(typeService, statementContext.getMethodResolutionService(), null, statementContext.getSchedulingService(), statementContext.getVariableService(), evaluatorContextStmt, statementContext.getEventAdapterService(), statementContext.getStatementName(), statementContext.getStatementId(), statementContext.getAnnotations(), statementContext.getContextDescriptor());
            ExprNode validated = ExprNodeUtility.getValidatedSubtree(createDesc.getAssignment(), validationContext);
            value = validated.getExprEvaluator().evaluate(null, true, evaluatorContextStmt);
        }

        // Create variable
        try
        {
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
158
                        "} or a plug-in single-row function or script but received '" + hashFuncName + "'");
                }
            }

            // get first parameter
            ExprNode paramExpr = item.getFunction().getParameters().get(0);
            ExprEvaluator eval = paramExpr.getExprEvaluator();
            Class paramType = eval.getType();
            EventPropertyGetter getter;

            if (hashFunction == HashFunctionEnum.CONSISTENT_HASH_CRC32) {
                if (item.getFunction().getParameters().size() > 1 || paramType != String.class) {
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
        // categorized
        else if (detailParent.getType() == EsperEPL2Ast.CREATE_CTX_CAT){
            List<ContextDetailCategoryItem> items = new ArrayList<ContextDetailCategoryItem>();
            for (int i = 0; i < detailParent.getChildCount() -1; i++) {
                Tree categoryParent = detailParent.getChild(i);
                ExprNode exprNode = astExprNodeMap.remove(categoryParent.getChild(0));
                String name = categoryParent.getChild(1).getText();
                items.add(new ContextDetailCategoryItem(exprNode, name));
            }
            filterSpec = ASTExprHelper.walkFilterSpec(detailParent.getChild(detailParent.getChildCount() - 1), propertyEvalSpec, astExprNodeMap);
            contextDetail = new ContextDetailCategory(items, filterSpec);
View Full Code Here
34
35
36
37
38
39
40
41
42
     * @param astExprNodeMap map to remove node from
     * @return expression
     */
    public static ExprNode getRemoveExpr(Tree child, Map<Tree, ExprNode> astExprNodeMap)
    {
        ExprNode thisEvalNode = astExprNodeMap.get(child);
        astExprNodeMap.remove(child);
        return thisEvalNode;
    }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
        List<ExprNode> exprNodes = new LinkedList<ExprNode>();

        for (int i = startIndex; i < parentNode.getChildCount(); i++)
        {
          Tree currentNode = parentNode.getChild(i);
            ExprNode exprNode = astExprNodeMap.get(currentNode);
            if (exprNode == null)
            {
                throw new IllegalStateException("Expression node for AST node not found for type " + currentNode.getType() + " and text " + currentNode.getText());
            }
            exprNodes.add(exprNode);
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
        return exprNodes;
    }

    public static ExprTimePeriod getTimePeriodExpr(Tree node, Map<Tree, ExprNode> astExprNodeMap) {

        ExprNode nodes[] = new ExprNode[8];
        for (int i = 0; i < node.getChildCount(); i++)
        {
            Tree child = node.getChild(i);
            if (child.getType() == EsperEPL2Ast.MILLISECOND_PART)
            {
View Full Code Here
TOP

Related Classes of com.espertech.esper.epl.expression.ExprNode

  • com.espertech.esper.antlr.ASTUtil
  • com.espertech.esper.core.context.mgr.ContextControllerHashFactory
  • com.espertech.esper.core.EPAdministratorImpl
  • com.espertech.esper.core.service.EPAdministratorImpl
  • com.espertech.esper.core.start.EPPreparedExecuteInsertInto
  • com.espertech.esper.core.start.EPPreparedExecuteSingleStreamUpdate
  • com.espertech.esper.core.start.EPStatementStartMethodCreateVariable
  • com.espertech.esper.dataflow.ops.Filter
  • com.espertech.esper.epl.agg.rollup.GroupByExpressionHelper
  • com.espertech.esper.epl.core.ColumnNamedNodeSwapper
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.