code: 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;
      }
    }
docs: Instantiates ingest thread for the current edits segment.