Package org.apache.pig.tools.grunt

Examples of org.apache.pig.tools.grunt.Grunt.exec()

872
873
874
875
876
877
878
879
880
881
882
           
            strCmd = "sh bash -c 'echo hello world > tempShFileToTestShCommand'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();
            BufferedReader fileReader = null;
            fileReader = new BufferedReader(new FileReader("tempShFileToTestShCommand"));
            assertTrue(fileReader.readLine().equalsIgnoreCase("hello world"));
            fileReader.close();
            strCmd = "sh rm tempShFileToTestShCommand";
View Full Code Here
881
882
883
884
885
886
887
888
889
890
891
            fileReader.close();
            strCmd = "sh rm tempShFileToTestShCommand";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();
            assertFalse(new File("tempShFileToTestShCommand").exists());

            strCmd = "sh bash -c 'touch TouchedFileInsideGrunt_61 | ls | grep TouchedFileInsideGrunt_61 > fileContainingTouchedFileInsideGruntShell_71'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
View Full Code Here
888
889
890
891
892
893
894
895
896
897
898
            strCmd = "sh bash -c 'touch TouchedFileInsideGrunt_61 | ls | grep TouchedFileInsideGrunt_61 > fileContainingTouchedFileInsideGruntShell_71'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();
            fileReader = new BufferedReader(new FileReader("fileContainingTouchedFileInsideGruntShell_71"));
            assertTrue(fileReader.readLine().equals("TouchedFileInsideGrunt_61"));
            fileReader.close();
            strCmd = "sh bash -c 'rm fileContainingTouchedFileInsideGruntShell_71'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
View Full Code Here
896
897
898
899
900
901
902
903
904
905
906
            fileReader.close();
            strCmd = "sh bash -c 'rm fileContainingTouchedFileInsideGruntShell_71'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();
            assertFalse(new File("fileContainingTouchedFileInsideGruntShell_71").exists());
            strCmd = "sh bash -c 'rm TouchedFileInsideGrunt_61'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
View Full Code Here
902
903
904
905
906
907
908
909
910
911
912
            assertFalse(new File("fileContainingTouchedFileInsideGruntShell_71").exists());
            strCmd = "sh bash -c 'rm TouchedFileInsideGrunt_61'";
            cmd = new ByteArrayInputStream(strCmd.getBytes());
            reader = new InputStreamReader(cmd);
            grunt = new Grunt(new BufferedReader(reader), context);
            grunt.exec();
            assertFalse(new File("TouchedFileInsideGrunt_61").exists());
        
           
        } catch (ExecException e) {
            e.printStackTrace();
View Full Code Here
927
928
929
930
931
932
933
934
935
936
937
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);

        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        grunt.exec();
        assertEquals("high", context.getProperties().getProperty(PigContext.JOB_PRIORITY));
    }
   
    @Test
    public void testSetWithQuotes() throws Throwable {
View Full Code Here
943
944
945
946
947
948
949
950
951
952
953
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);

        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        grunt.exec();
        assertEquals("high", context.getProperties().getProperty(PigContext.JOB_PRIORITY));
    }
   
    @Test   
    public void testRegisterWithQuotes() throws Throwable {
View Full Code Here
959
960
961
962
963
964
965
966
967
968
969
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);

        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        grunt.exec();
        assertTrue(context.extraJars.contains(ClassLoader.getSystemResource("pig-withouthadoop.jar")));
    }
   
    @Test   
    public void testRegisterWithoutQuotes() throws Throwable {
View Full Code Here
975
976
977
978
979
980
981
982
983
984
985
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);

        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        grunt.exec();
        assertTrue(context.extraJars.contains(ClassLoader.getSystemResource("pig-withouthadoop.jar")));
    }
   
    @Test
    public void testRegisterScripts() throws Throwable {
View Full Code Here
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
        ByteArrayInputStream cmd = new ByteArrayInputStream(strCmd.getBytes());
        InputStreamReader reader = new InputStreamReader(cmd);

        Grunt grunt = new Grunt(new BufferedReader(reader), context);

        grunt.exec();
        assertTrue(context.getFuncSpecFromAlias("pig.square") != null);

    }
    /*
    @Test   
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.