public boolean getStatusAgg ( byte [ ] row , byte [ ] col ) throws IOException { Get g = new Get ( row ) ; g . addColumn ( Constants . INFO_FAM_BYTES , col ) ; Table rawTable = null ; Cell cell = null ; try { rawTable = hbaseConnection . getTable ( TableName . valueOf ( Constants . HISTORY_RAW_TABLE ) ) ; Result r = rawTable . get ( g ) ; cell = r . getColumnLatestCell ( Constants . INFO_FAM_BYTES , col ) ; } finally { if ( rawTable != null ) { rawTable . close ( ) ; } } boolean status = false ; try { if ( cell != null ) { status = Bytes . toBoolean ( CellUtil . cloneValue ( cell ) ) ; } } catch ( IllegalArgumentException iae ) { LOG . error ( "Caught " + iae ) ; } LOG . info ( "Returning from Raw, " + Bytes . toString ( col ) + " for this job=" + status ) ; return status ; }
creates a Get to be fetch daily aggregation status from the RAW table