Examples of org.apache.pig.newplan.OperatorPlan.connect()

Class org.apache.pig.newplan.OperatorPlan

Examples of org.apache.pig.newplan.OperatorPlan.connect()

org.apache.pig.newplan.OperatorPlan.connect()
Connect two operators in the plan, controlling which position in the edge lists that the from and to edges are placed. @param from Operator edge will come from @param fromPos Position in the array for the from edge @param to Operator edge will go to @param toPos Position in the array for the to edge

        pattern.add(s1);
        pattern.add(s2);
        pattern.add(s3);
        pattern.add(s4);
        pattern.connect(s1, s2);
        pattern.connect(s1, s3);
        pattern.connect(s1, s4);


        Rule r = new SillyRule("basic", pattern);
        List<OperatorPlan> l = r.match(plan);
        assertEquals(1, l.size());

View Full Code Here

        pattern.add(s2);
        pattern.add(s3);
        pattern.add(s4);
        pattern.connect(s1, s2);
        pattern.connect(s1, s3);
        pattern.connect(s1, s4);


        Rule r = new SillyRule("basic", pattern);
        List<OperatorPlan> l = r.match(plan);
        assertEquals(1, l.size());

View Full Code Here

            
            foreach.setInnerPlan( innerPlan );
            foreach.setAlias(union.getAlias());
            Pair<Integer, Integer> pair = plan.disconnect( pred, union );
            plan.add( foreach );
            plan.connect( pred, pair.first, foreach, 0 );
            plan.connect( foreach, 0, union, pair.second );
        }
        
        union.setUnionOnSchema(false);
    }

View Full Code Here

            foreach.setInnerPlan( innerPlan );
            foreach.setAlias(union.getAlias());
            Pair<Integer, Integer> pair = plan.disconnect( pred, union );
            plan.add( foreach );
            plan.connect( pred, pair.first, foreach, 0 );
            plan.connect( foreach, 0, union, pair.second );
        }
        
        union.setUnionOnSchema(false);
    }

View Full Code Here

      throws FrontendException {
  // connect the foreach operator with predecessors of cube operator
  List<Operator> opers = op.getPlan().getPredecessors(op);
  for (Operator oper : opers) {
      OperatorPlan foreachPlan = foreach.getPlan();
      foreachPlan.connect(oper, (Operator) foreach);
  }


  // disconnect the cube operator from the plan
  opers = foreach.getPlan().getPredecessors(foreach);
  for (Operator lop : opers) {

View Full Code Here

      throws FrontendException {
  // connect the foreach operator with predecessors of cube operator
  List<Operator> opers = op.getPlan().getPredecessors(op);
  for (Operator oper : opers) {
      OperatorPlan foreachPlan = foreach.getPlan();
      foreachPlan.connect(oper, (Operator) foreach);
  }


  // disconnect the cube operator from the plan
  opers = foreach.getPlan().getPredecessors(foreach);
  for (Operator lop : opers) {

View Full Code Here

            
            foreach.setInnerPlan( innerPlan );
            foreach.setAlias(union.getAlias());
            Pair<Integer, Integer> pair = plan.disconnect( pred, union );
            plan.add( foreach );
            plan.connect( pred, pair.first, foreach, 0 );
            plan.connect( foreach, 0, union, pair.second );
        }
        
        union.setUnionOnSchema(false);
    }

View Full Code Here

            foreach.setInnerPlan( innerPlan );
            foreach.setAlias(union.getAlias());
            Pair<Integer, Integer> pair = plan.disconnect( pred, union );
            plan.add( foreach );
            plan.connect( pred, pair.first, foreach, 0 );
            plan.connect( foreach, 0, union, pair.second );
        }
        
        union.setUnionOnSchema(false);
    }

View Full Code Here

         Operator op2 = new OP_Filter("mmm2", pattern);
         Operator op3 = new OP_Join("mmm3", pattern);
         pattern.add(op1);
         pattern.add(op2);
         pattern.add(op3);
         pattern.connect(op1, op3);
         pattern.connect(op2, op3);
         
         Rule r = new SillyRule("basic", pattern);
         List<OperatorPlan> l = r.match(plan);
         assertEquals(1, l.size());

View Full Code Here

         Operator op3 = new OP_Join("mmm3", pattern);
         pattern.add(op1);
         pattern.add(op2);
         pattern.add(op3);
         pattern.connect(op1, op3);
         pattern.connect(op2, op3);
         
         Rule r = new SillyRule("basic", pattern);
         List<OperatorPlan> l = r.match(plan);
         assertEquals(1, l.size());
         OperatorPlan match = l.get(0);

View Full Code Here

0 1 2 3

TOP

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.