Package org.apache.pig.backend.hadoop.executionengine.physicalLayer

Examples of org.apache.pig.backend.hadoop.executionengine.physicalLayer.LogToPhyTranslationVisitor.visit()

229
230
231
232
233
234
235
236
237
238
239
        try {
            LogToPhyTranslationVisitor translator =
                new LogToPhyTranslationVisitor(plan);
            translator.setPigContext(pigContext);
            translator.visit();
            return translator.getPhysicalPlan();
        } catch (VisitorException ve) {
            int errCode = 2042;
            String msg = "Internal error. Unable to translate logical plan to physical plan.";
            throw new ExecException(msg, errCode, PigException.BUG, ve);
View Full Code Here
298
299
300
301
302
303
304
305
306
307
308
               
            }else{      
                LogToPhyTranslationVisitor translator =
                    new LogToPhyTranslationVisitor(plan);
                translator.setPigContext(pigContext);
                translator.visit();
                return translator.getPhysicalPlan();
            }
        } catch (Exception ve) {
            int errCode = 2042;
            String msg = "Error in new logical plan. Try -Dpig.usenewlogicalplan=false.";
View Full Code Here
795
796
797
798
799
800
801
802
803
804
805
    }
   
    public PhysicalPlan buildPhysicalPlan(LogicalPlan lp) throws VisitorException {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }
   
    public LogicalPlan buildPlan(String query) {
        return buildPlan(query, LogicalPlanBuilder.class.getClassLoader());
View Full Code Here
544
545
546
547
548
549
550
551
552
553
554
    }
   
    public static PhysicalPlan buildPhysicalPlan(LogicalPlan lp, PigContext pc) throws Exception {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }

    /**
     * migrate old logical plan to new logical plan
View Full Code Here
278
279
280
281
282
283
284
285
286
287
288
               
            }else{      
                LogToPhyTranslationVisitor translator =
                    new LogToPhyTranslationVisitor(plan);
                translator.setPigContext(pigContext);
                translator.visit();
                return translator.getPhysicalPlan();
            }
        } catch (Exception ve) {
            int errCode = 2042;
            String msg = "Internal error. Unable to translate logical plan to physical plan.";
View Full Code Here
462
463
464
465
466
467
468
469
470
471
472
    }
   
    public static PhysicalPlan buildPhysicalPlan(LogicalPlan lp, PigContext pc) throws Exception {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }
   
    public static MROperPlan buildMRPlan(PhysicalPlan pp, PigContext pc) throws Exception{
        MRCompiler comp = new MRCompiler(pp, pc);
View Full Code Here
807
808
809
810
811
812
813
814
815
816
817
    }
   
    public PhysicalPlan buildPhysicalPlan(LogicalPlan lp) throws VisitorException {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }
   
    public LogicalPlan buildPlan(String query) {
        return buildPlan(query, LogicalPlanBuilder.class.getClassLoader());
View Full Code Here
302
303
304
305
306
307
308
309
310
311
312
               
            }else{      
                LogToPhyTranslationVisitor translator =
                    new LogToPhyTranslationVisitor(plan);
                translator.setPigContext(pigContext);
                translator.visit();
                return translator.getPhysicalPlan();
            }
        } catch (Exception ve) {
            int errCode = 2042;
            String msg = "Error in new logical plan. Try -Dpig.usenewlogicalplan=false.";
View Full Code Here
412
413
414
415
416
417
418
419
420
421
422
    }
   
    public static PhysicalPlan buildPhysicalPlan(LogicalPlan lp, PigContext pc) throws Exception {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }
   
    public static MROperPlan buildMRPlan(PhysicalPlan pp, PigContext pc) throws Exception{
        MRCompiler comp = new MRCompiler(pp, pc);
View Full Code Here
759
760
761
762
763
764
765
766
767
768
769
    }
   
    public PhysicalPlan buildPhysicalPlan(LogicalPlan lp) throws VisitorException {
      LogToPhyTranslationVisitor visitor = new LogToPhyTranslationVisitor(lp);
      visitor.setPigContext(pc);
      visitor.visit();
      return visitor.getPhysicalPlan();
    }
   
    public LogicalPlan buildPlan(String query) {
        return buildPlan(query, LogicalPlanBuilder.class.getClassLoader());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.