Examples of org.apache.pig.newplan.optimizer.Rule.match()

Package org.apache.pig.newplan.optimizer

Class org.apache.pig.newplan.optimizer.Rule

Examples of org.apache.pig.newplan.optimizer.Rule.match()

org.apache.pig.newplan.optimizer.Rule.match()
Search for all the sub-plans that matches the pattern defined by this rule. @return A list of all matched sub-plans. The returned plans arepartial views of the original OperatorPlan. Each is a sub-set of the original plan and represents the same topology as the pattern, but operators in the returned plan are the same objects as the original plan. Therefore, a call getPlan() from any node in the return plan would return the original plan. @param plan the OperatorPlan to look for matches to the pattern

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


        r = new SillyRule("basic", pattern);
        l = r.match(plan);
        assertEquals(l.size(), 1);


        // search for split then 2 filters
        pattern = new SillyPlan();
        s1 = new OP_Split("mmm1", pattern);

View Full Code Here

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


        r = new SillyRule("basic", pattern);
        l = r.match(plan);
        assertEquals(1, l.size());


        assertEquals(1, l.get(0).getSources().size());
        assertEquals(2, l.get(0).getSinks().size());
        assertEquals(3, l.get(0).size());

View Full Code Here

        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());


        assertEquals(1, l.get(0).getSources().size());
        assertEquals(3, l.get(0).getSinks().size());
        assertEquals(4, l.get(0).size());

View Full Code Here

            "b = filter a by (srcid < 20 and age < 30) or (name == 'foo' and age > 40);" +
            "store b into 'output';";
        LogicalPlan plan = buildPlan(new PigServer(pc), query);
        
        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

            "b = filter a by (srcid < 20) or (name == 'foo');" + 
            "store b into 'output';";
        LogicalPlan plan = Util.buildLp(new PigServer(pc), query);
        
        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

            "b = filter a by (srcid < 20 and age < 30) or (name == 'foo' and age > 40);" +
            "store b into 'output';";
        LogicalPlan plan = buildPlan(new PigServer(pc), query);


        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

            "b = filter a by (srcid < 20) or (name == 'foo');" +
            "store b into 'output';";
        LogicalPlan plan = Util.buildLp(new PigServer(pc), query);


        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

            "b = filter a by (srcid < 20 and age < 30) or (name == 'foo' and age > 40);" +
            "store b into 'output';";
        LogicalPlan plan = buildPlan(new PigServer(pc), query);
        
        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

            "b = filter a by (srcid < 20) or (name == 'foo');" + 
            "store b into 'output';";
        LogicalPlan plan = Util.buildLp(new PigServer(pc), query);
        
        Rule rule = new PartitionFilterOptimizer("test");
        List<OperatorPlan> matches = rule.match(plan);
        if (matches != null) {
            Transformer transformer = rule.getNewTransformer();
            for (OperatorPlan m : matches) {
                if (transformer.check(m)) {
                    transformer.transform(m);

View Full Code Here

         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);
         assertEquals(match.size(), 3);
         assertEquals(match.getSinks().size(), 1);
         assertEquals(match.getSinks().get(0), join);

View Full Code Here

0 1 2 3 4

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.