processing/src/main/java/org/apache/carbondata/processing/loading/sort/unsafe/merger/UnsafeIntermediateFileMerger.java
/**
   * Below method will be used to start storing process This method will get
   * all the temp files present in sort temp folder then it will create the
   * record holder heap and then it will read first record from each file and
   * initialize the heap
   *
   * @throws CarbonSortKeyAndGroupByException
   */
Below method will be used to start storing process This method will get
all the temp files present in sort temp folder then it will create the
record holder heap and then it will read first record from each file and
initialize the heap


Below method will be used to start storing process This method will get all the temp files present in sort temp folder then it will create the record holder heap and then it will read first record from each file and initialize the heap
private void startSorting() throws CarbonSortKeyAndGroupByException {
    LOGGER.info("Number of temp file: " + this.fileCounter);
    createRecordHolderQueue(intermediateFiles);
    LOGGER.info("Started adding first record from each file");
    SortTempChunkHolder sortTempFileChunkHolder = null;
    for (File tempFile : intermediateFiles) {
      sortTempFileChunkHolder = new UnsafeSortTempFileChunkHolder(tempFile, mergerParameters);
      sortTempFileChunkHolder.readRow();
      this.totalNumberOfRecords += sortTempFileChunkHolder.numberOfRows();
      this.recordHolderHeap.add(sortTempFileChunkHolder);
    }
    LOGGER.info("Heap Size" + this.recordHolderHeap.size());
  }
private void startSorting ( ) throws CarbonSortKeyAndGroupByException { LOGGER . info ( "Number of temp file: " + this . fileCounter ) ; createRecordHolderQueue ( intermediateFiles ) ; LOGGER . info ( "Started adding first record from each file" ) ; SortTempChunkHolder sortTempFileChunkHolder = null ; for ( File tempFile : intermediateFiles ) { sortTempFileChunkHolder = new UnsafeSortTempFileChunkHolder ( tempFile , mergerParameters ) ; sortTempFileChunkHolder . readRow ( ) ; this . totalNumberOfRecords += sortTempFileChunkHolder . numberOfRows ( ) ; this . recordHolderHeap . add ( sortTempFileChunkHolder ) ; } LOGGER . info ( "Heap Size" + this . recordHolderHeap . size ( ) ) ; }
Below method will be used to start storing process This method will get
 all the temp files present in sort temp folder then it will create the
 record holder heap and then it will read first record from each file and
 initialize the heap
Below method will be used to start storing process This method will get all the temp files present in sort temp folder then it will create the record holder heap and then it will read first record from each file and initialize the heap
// create record holder heap // iterate over file list and create chunk holder and add to heap // create chunk holder // add to heap