private void setupCurrentEditStream ( long txid ) throws IOException { // get new stream currentEditLogInputStream = JournalSet . getInputStream ( remoteJournalManager , txid ) ; // we just started a new log segment currentSegmentTxId = txid ; // indicate that we successfully reopened the stream mostRecentlyReadTransactionTime = now ( ) ; }
Setup the input stream to be consumed by the reader . The input stream corresponds to a single segment .