public String getRawJobHistory(QualifiedJobId jobId) throws IOException {
    String historyData = null;
    byte[] rowKey = idConv.toBytes(jobId);
    Get get = new Get(rowKey);
    get.addColumn(Constants.RAW_FAM_BYTES, Constants.JOBHISTORY_COL_BYTES);
    Table rawTable = null;
    try {
      rawTable = hbaseConnection
          .getTable(TableName.valueOf(Constants.HISTORY_RAW_TABLE));
      Result result = rawTable.get(get);
      if (result != null && !result.isEmpty()) {
        historyData = Bytes.toString(result.getValue(Constants.RAW_FAM_BYTES,
            Constants.JOBHISTORY_COL_BYTES));
      }
    } finally {
      if (rawTable != null) {
        rawTable.close();
      }
    }

    return historyData;
  }
public String getRawJobHistory ( QualifiedJobId jobId ) throws IOException { String historyData = null ; byte [ ] rowKey = idConv . toBytes ( jobId ) ; Get get = new Get ( rowKey ) ; get . addColumn ( Constants . RAW_FAM_BYTES , Constants . JOBHISTORY_COL_BYTES ) ; Table rawTable = null ; try { rawTable = hbaseConnection . getTable ( TableName . valueOf ( Constants . HISTORY_RAW_TABLE ) ) ; Result result = rawTable . get ( get ) ; if ( result != null && ! result . isEmpty ( ) ) { historyData = Bytes . toString ( result . getValue ( Constants . RAW_FAM_BYTES , Constants . JOBHISTORY_COL_BYTES ) ) ; } } finally { if ( rawTable != null ) { rawTable . close ( ) ; } } return historyData ; }
Returns the raw job history file stored for the given cluster and job ID.
@param jobId the cluster and job ID to look up
@return the stored job history file contents or {@code null} if no
corresponding record was found
@throws IOException