private void instantiateIngest ( ) throws IOException { InjectionHandler . processEvent ( InjectionEvent . STANDBY_INSTANTIATE_INGEST ) ; try { synchronized ( ingestStateLock ) { if ( checkIngestState ( ) ) { LOG . info ( "Standby: Ingest for txid: " + currentSegmentTxId + " is already running" ) ; return ; } assertState ( StandbyIngestState . NOT_INGESTING ) ; ingest = new Ingest ( this , fsnamesys , confg , currentSegmentTxId ) ; ingestThread = new Thread ( ingest ) ; ingestThread . setName ( "Ingest_for_" + currentSegmentTxId ) ; ingestThread . start ( ) ; currentIngestState = StandbyIngestState . INGESTING_EDITS ; } LOG . info ( "Standby: Instatiated ingest for txid: " + currentSegmentTxId ) ; } catch ( IOException e ) { setIngestFailures ( ingestFailures + 1 ) ; currentIngestState = StandbyIngestState . NOT_INGESTING ; throw e ; } }
Instantiates ingest thread for the current edits segment .