Package org.apache.pig.experimental.plan

Examples of org.apache.pig.experimental.plan.OperatorSubPlan

200
201
202
203
204
205
206
207
208
209
210
            if( ! ( opSet != null && opSet.size() > 0 ) ) {
                return;
            }
            Operator filterSuc = opSet.get(0);
           
            subPlan = new OperatorSubPlan(currentPlan);
           
            // Steps below do the following
            /*
             *          ForEachPred
             *               |
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
            return false;
        }

        @Override
        public void transform(OperatorPlan matched) throws IOException {
            subPlan = new OperatorSubPlan(currentPlan);
           
            // split one LOFilter into 2 by "AND"
            LOFilter filter = (LOFilter)matched.getSources().get(0);
            LogicalExpressionPlan cond = filter.getFilterPlan();
            LogicalExpression root = (LogicalExpression) cond.getSources().get(0);
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
    public ColumnPruneHelper(OperatorPlan currentPlan) {
        this.currentPlan = currentPlan;
    }   
   
    private OperatorSubPlan getSubPlan() throws IOException {
        OperatorSubPlan p = null;
        if (currentPlan instanceof OperatorSubPlan) {
            p = new OperatorSubPlan(((OperatorSubPlan)currentPlan).getBasePlan());
        } else {
            p = new OperatorSubPlan(currentPlan);
        }
        Iterator<Operator> iter = currentPlan.getOperators();
       
        while(iter.hasNext()) {
            Operator op = iter.next();
View Full Code Here
77
78
79
80
81
82
83
84
85
86
   
    public MapKeysPruneHelper(OperatorPlan currentPlan) {
        this.currentPlan = currentPlan;
       
        if (currentPlan instanceof OperatorSubPlan) {
            subplan = new OperatorSubPlan(((OperatorSubPlan)currentPlan).getBasePlan());
        } else {
            subplan = new OperatorSubPlan(currentPlan);
        }
    }
View Full Code Here
86
87
88
89
90
91
92
93
       
        @Override
        public void transform(OperatorPlan matched) throws IOException {           
            addForeach(opForAdd);
           
            subPlan = new OperatorSubPlan(currentPlan);
            addSuccessors(opForAdd);
        }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
            return false;
        }

        @Override
        public void transform(OperatorPlan matched) throws IOException {    
            subPlan = new OperatorSubPlan(currentPlan);
           
            LOFilter filter = (LOFilter)matched.getSources().get(0);

            subPlan.add(filter);
           
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
            return false;
        }

        @Override
        public void transform(OperatorPlan matched) throws IOException {
            subPlan = new OperatorSubPlan(currentPlan);

            LOJoin join = (LOJoin)matched.getSources().get(0);
            subPlan.add(join);    
           
            Operator next = matched.getSinks().get(0);
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
        }
       
        @SuppressWarnings("unchecked")
        private void merge() {
            // combine two subplans
            subPlan = new OperatorSubPlan(currentPlan);
            if (columnPrune) {
                Iterator<Operator> iter = columnHelper.reportChanges().getOperators();
                while(iter.hasNext()) {
                    subPlan.add(iter.next());
                }
View Full Code Here
TOP

Related Classes of org.apache.pig.experimental.plan.OperatorSubPlan

  • org.apache.pig.experimental.logical.rules.AddForEach$AddForEachTransformer
  • org.apache.pig.experimental.logical.rules.ColumnMapKeyPrune$ColumnMapKeyPruneTransformer
  • org.apache.pig.experimental.logical.rules.ColumnPruneHelper
  • org.apache.pig.experimental.logical.rules.FilterAboveForeach$FilterAboveForEachTransformer
  • org.apache.pig.experimental.logical.rules.MapKeysPruneHelper
  • org.apache.pig.experimental.logical.rules.MergeFilter$MergeFilterTransformer
  • org.apache.pig.experimental.logical.rules.PushUpFilter$PushUpFilterTransformer
  • org.apache.pig.experimental.logical.rules.SplitFilter$SplitFilterTransformer
    • 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.