@Test(expected = IllegalStateException.class) public void testGetMrJobIdThrowsIllegalStateException() throws IOException { Job job = Job.getInstance(new Configuration(false)); HadoopCmdOutput hadoopCmdOutput = new HadoopCmdOutput(job, new StringBuilder()); assertNull(hadoopCmdOutput.getMrJobId()); }
public String getMrJobId() { return getInfo().get(ExecutableConstants.MR_JOB_ID); }
HadoopCmdOutput { public String getMrJobId() { return getInfo().get(ExecutableConstants.MR_JOB_ID); } }
HadoopCmdOutput { public String getMrJobId() { return getInfo().get(ExecutableConstants.MR_JOB_ID); } HadoopCmdOutput(Job job, StringBuilder output); }
HadoopCmdOutput { public String getMrJobId() { return getInfo().get(ExecutableConstants.MR_JOB_ID); } HadoopCmdOutput(Job job, StringBuilder output); String getMrJobId(); Map<String, String> getInfo(); String getMapInputRecords(); String getHdfsBytesWritten(); String getRawInputBytesRead(); void updateJobCounter(); }
HadoopCmdOutput { public String getMrJobId() { return getInfo().get(ExecutableConstants.MR_JOB_ID); } HadoopCmdOutput(Job job, StringBuilder output); String getMrJobId(); Map<String, String> getInfo(); String getMapInputRecords(); String getHdfsBytesWritten(); String getRawInputBytesRead(); void updateJobCounter();  }