public static Map < String , Map < String , String > > getJournalStats ( Collection < Journal > journals ) { Map < String , Map < String , String > > stats = new HashMap < String , Map < String , String > > ( ) ; for ( Journal j : journals ) { try { Map < String , String > stat = new HashMap < String , String > ( ) ; stats . put ( j . getJournalId ( ) , stat ) ; stat . put ( "Txid committed" , Long . toString ( j . getCommittedTxnId ( ) ) ) ; stat . put ( "Txid segment" , Long . toString ( j . getCurrentSegmentTxId ( ) ) ) ; stat . put ( "Txid written" , Long . toString ( j . getHighestWrittenTxId ( ) ) ) ; stat . put ( "Current lag" , Long . toString ( j . getCurrentLagTxns ( ) ) ) ; stat . put ( "Writer epoch" , Long . toString ( j . getLastWriterEpoch ( ) ) ) ; } catch ( IOException e ) { LOG . error ( "Error when collectng stats" , e ) ; } } return stats ; }
Get journal stats for webui .