()
| 307 | } |
| 308 | |
| 309 | public void connect() throws ExecException { |
| 310 | executionEngine.init(); |
| 311 | dfs = executionEngine.getDataStorage(); |
| 312 | lfs = new HDataStorage(URI.create("file:///"), properties); |
| 313 | } |
| 314 | |
| 315 | public void setJobtrackerLocation(String newLocation) { |
| 316 | executionEngine.setProperty(MRConfiguration.JOB_TRACKER, newLocation); |