Package org.apache.pig.newplan.logical.expression

Examples of org.apache.pig.newplan.logical.expression.LogicalExpressionVisitor

1584
1585
1586
1587
1588
1589
1590
1591
1592
1593
1594
                // that operator is also going to be enqueued.
                currOp.accept( new AllExpressionVisitor( plan, new DependencyOrderWalker( plan ) ) {
                        @Override
                        protected LogicalExpressionVisitor getVisitor(LogicalExpressionPlan exprPlan)
                        throws FrontendException {
                            return new LogicalExpressionVisitor( exprPlan, new DependencyOrderWalker( exprPlan ) ) {
                                @Override
                                public void visit(ScalarExpression expr) throws FrontendException {
                                    Operator refOp = expr.getImplicitReferencedOperator();
                                    if( !queue.contains( refOp ) )
                                        queue.add( refOp );
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    }

    @Override
    protected LogicalExpressionVisitor getVisitor(LogicalExpressionPlan exprPlan)
    throws FrontendException {
        return new LogicalExpressionVisitor( exprPlan, new DependencyOrderWalker( exprPlan ) ) {
            @Override
            public void visit(ProjectExpression expr) throws FrontendException {
                expr.setColumnNumberFromAlias();
            }
View Full Code Here
66
67
68
69
70
71
72
73
74
     */
    abstract protected LogicalExpressionVisitor getVisitor(LogicalExpressionPlan expr) throws FrontendException;
   
    private void visitAll(Collection<LogicalExpressionPlan> lexpPlans) throws FrontendException {
  for (LogicalExpressionPlan plan : lexpPlans) {
      LogicalExpressionVisitor v = getVisitor(plan);
      v.visit();
  }
    }
View Full Code Here
74
75
76
77
78
79
80
81
    }
   
    @Override
    public void visit(LOFilter filter) throws FrontendException {
        currentOp = filter;
        LogicalExpressionVisitor v = getVisitor(filter.getFilterPlan());
        v.visit();
    }
View Full Code Here
82
83
84
85
86
87
88
89
90
   
    @Override
    public void visit(LOLimit limit) throws FrontendException {
        currentOp = limit;
        if (limit.getLimitPlan() != null) {
            LogicalExpressionVisitor v = getVisitor(limit.getLimitPlan());
            v.visit();
        }
    }
View Full Code Here
136
137
138
139
140
141
142
143
        // the expression in LOInnerLoad contains info relative from LOForEach
        // so use LOForeach as currentOp
        currentOp = load.getLOForEach();
        LogicalExpressionPlan exp = (LogicalExpressionPlan)load.getProjection().getPlan();
      
        LogicalExpressionVisitor v = getVisitor(exp);
        v.visit();      
    }
View Full Code Here
143
144
145
146
147
148
149
150
    }
   
    @Override
    public void visit(LOSplitOutput splitOutput) throws FrontendException {
        currentOp = splitOutput;
        LogicalExpressionVisitor v = getVisitor(splitOutput.getFilterPlan());
        v.visit();
    }
View Full Code Here
1561
1562
1563
1564
1565
1566
1567
1568
1569
1570
1571
                // that operator is also going to be enqueued.
                currOp.accept( new AllExpressionVisitor( plan, new DependencyOrderWalker( plan ) ) {
                        @Override
                        protected LogicalExpressionVisitor getVisitor(LogicalExpressionPlan exprPlan)
                        throws FrontendException {
                            return new LogicalExpressionVisitor( exprPlan, new DependencyOrderWalker( exprPlan ) ) {
                                @Override
                                public void visit(ScalarExpression expr) throws FrontendException {
                                    Operator refOp = expr.getImplicitReferencedOperator();
                                    if( !queue.contains( refOp ) )
                                        queue.add( refOp );
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    }

    @Override
    protected LogicalExpressionVisitor getVisitor(final LogicalExpressionPlan exprPlan)
    throws FrontendException {
        return new LogicalExpressionVisitor( exprPlan, new DependencyOrderWalker( exprPlan ) ) {

            @Override
            public void visit(ScalarExpression expr) throws FrontendException {
                // This is a scalar udf.
                ConstantExpression filenameConst = (ConstantExpression)exprPlan.getSuccessors( expr ).get( 1 );
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
        LogicalPlan plan = validate( query );
        System.out.println( "Plan after setter: " + plan.toString() );
        new AllExpressionVisitor( plan, new DependencyOrderWalker( plan ) ) {
            @Override
            protected LogicalExpressionVisitor getVisitor(LogicalExpressionPlan exprPlan) throws FrontendException {
                return new LogicalExpressionVisitor( exprPlan, new DependencyOrderWalker( exprPlan ) ) {
                    @Override
                    public void visit(ProjectExpression expr) throws FrontendException {
                        Assert.assertTrue( null == expr.getColAlias() );
                        Assert.assertTrue( expr.getColNum() >= -1 );
                    }
View Full Code Here
TOP

Related Classes of org.apache.pig.newplan.logical.expression.LogicalExpressionVisitor

  • org.apache.pig.newplan.logical.optimizer.AllExpressionVisitor
  • org.apache.pig.newplan.logical.visitor.ColumnAliasConversionVisitor
  • org.apache.pig.newplan.logical.visitor.ScalarVisitor
  • org.apache.pig.parser.TestColumnAliasConversion
  • org.apache.pig.PigServer$Graph
  • org.apache.pig.impl.logicalLayer.FrontendException
    • 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.