processing/src/main/java/org/apache/carbondata/processing/sort/sortdata/SortDataRows.java
/**
   * This method will be used to initialize
   */
This method will be used to initialize
This method will be used to initialize
public void initialize() throws CarbonSortKeyAndGroupByException {
    this.recordHolderList = new Object[sortBufferSize][];
    deleteSortLocationIfExists();
    CarbonDataProcessorUtil.createLocations(parameters.getTempFileLocation());
    this.dataSorterAndWriterExecutorService = Executors
        .newFixedThreadPool(parameters.getNumberOfCores(),
            new CarbonThreadFactory("SortDataRowPool:" + parameters.getTableName()));
    semaphore = new Semaphore(parameters.getNumberOfCores());
  }
public void initialize ( ) throws CarbonSortKeyAndGroupByException { this . recordHolderList = new Object [ sortBufferSize ] [ ] ; deleteSortLocationIfExists ( ) ; CarbonDataProcessorUtil . createLocations ( parameters . getTempFileLocation ( ) ) ; this . dataSorterAndWriterExecutorService = Executors . newFixedThreadPool ( parameters . getNumberOfCores ( ) , new CarbonThreadFactory ( "SortDataRowPool:" + parameters . getTableName ( ) ) ) ; semaphore = new Semaphore ( parameters . getNumberOfCores ( ) ) ; }
This method will be used to initialize
This method will be used to initialize
// create holder list which will hold incoming rows // size of list will be sort buffer size + 1 to avoid creation of new // array in list array // Delete if any older file exists in sort temp folder // create new sort temp directory