public Configuration getRawJobConfiguration ( QualifiedJobId jobId ) throws IOException { Configuration conf = null ; byte [ ] rowKey = idConv . toBytes ( jobId ) ; Get get = new Get ( rowKey ) ; get . addColumn ( Constants . RAW_FAM_BYTES , Constants . JOBCONF_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 ( ) ) { conf = createConfigurationFromResult ( result ) ; } } catch ( MissingColumnInResultException e ) { LOG . error ( "Failed to retrieve configuration from row returned for " + jobId , e ) ; } finally { if ( rawTable != null ) { rawTable . close ( ) ; } } return conf ; }
Returns the raw job configuration stored for the given cluster and job ID