Package org.apache.pig.tools.grunt

Examples of org.apache.pig.tools.grunt.Grunt

511
512
513
514
515
516
517
518
519
                + "store a into 'bar'; exec; a = load 'bar'; store a into 'baz';\n";
       
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
542
543
544
545
546
547
548
549
550
            +"rm bar;\n";
       
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
567
568
569
570
571
572
573
574
575
            +"rm /tmp/bar; rm /tmp/foo/baz;";
       
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
591
592
593
594
595
596
597
598
599
            +"dump g;";

        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
615
616
617
618
619
620
621
622
623
            +"illustrate g;";

        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
645
646
647
648
649
650
651
652
653
            +"cat bar;";
           
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);
   
        grunt.exec();
    }
View Full Code Here
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
            +"cat baz;";
           
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        boolean caught = false;
        try {
            grunt.exec();
        } catch (Exception e) {
            caught = true;
            assertTrue(e.getMessage().contains("baz does not exist"));
        }
        assertTrue(caught);
View Full Code Here
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
            "run -param -param;";
           
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        boolean caught = false;
        try {
            grunt.exec();
        } catch (ParseException e) {
            caught = true;
            assertTrue(e.getMessage().contains("Encountered"));
        }
        assertTrue(caught);
View Full Code Here
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
            +"cp pre done;\n";
           
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);
       
        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        boolean caught = false;
        try {
            grunt.exec();
        } catch (PigException e) {
            caught = true;
            assertTrue(e.getErrorCode() == 6017);
        }
View Full Code Here
766
767
768
769
770
771
772
773
774
775
776
777
                +"fs -rm /tmp/foo/baz;";
           
            ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
            InputStreamReader reader = new InputStreamReader(cmd);
           
            Grunt grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();

        } catch (ExecException e) {
            e.printStackTrace();
            fail();
        } catch (Throwable e) {
View Full Code Here
TOP

Related Classes of org.apache.pig.tools.grunt.Grunt

  • Example1
  • org.apache.pig.Main
  • org.apache.pig.PigServer
  • org.apache.pig.test.TestGrunt
  • org.apache.pig.test.TestMacroExpansion
  • org.apache.pig.test.TestPigServer
  • org.apache.pig.test.TestShortcuts
  • org.apache.pig.test.TestUTF8
  • org.apache.pig.tools.grunt.GruntParser
  • org.apache.pig.tools.grunt.PigCompletor
    • 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.