()
| 92 | } |
| 93 | |
| 94 | @Before |
| 95 | public void setUp() throws Exception{ |
| 96 | pigServer = new PigServer(cluster.getExecType(), cluster.getProperties()); |
| 97 | pigServer.getPigContext().getExecutionEngine().setProperty(PigConfiguration.PIG_OPT_FETCH, "false"); |
| 98 | pigServer.getPigContext().getExecutionEngine().setProperty(PigConfiguration.PIG_AUTO_LOCAL_ENABLED, String.valueOf("true")); |
| 99 | pigServer.getPigContext().getExecutionEngine().setProperty(PigConfiguration.PIG_AUTO_LOCAL_INPUT_MAXBYTES, "200"); |
| 100 | |
| 101 | Logger logger = Logger.getLogger(JobControlCompiler.class); |
| 102 | logger.removeAllAppenders(); |
| 103 | logger.setLevel(Level.INFO); |
| 104 | SimpleLayout layout = new SimpleLayout(); |
| 105 | logFile = File.createTempFile("log", ""); |
| 106 | FileAppender appender = new FileAppender(layout, logFile.toString(), false, false, 0); |
| 107 | logger.addAppender(appender); |
| 108 | |
| 109 | miniFileName = createInputFile("miniFile", 10).getAbsolutePath(); |
| 110 | smallFileName = createInputFile("smallFile", 100).getAbsolutePath(); |
| 111 | bigFileName = createInputFile("bigFile", 1000).getAbsolutePath(); |
| 112 | } |
| 113 | |
| 114 | @AfterClass |
| 115 | public static void oneTimeTearDown() throws Exception { |
nothing calls this directly
no test coverage detected