private void startIntermediateMerging(File[] intermediateFiles){
  File file=new File(this.tempFileLocation + File.separator + this.tableName+ System.nanoTime()+ CarbonCommonConstants.MERGERD_EXTENSION);
  FileMergerParameters parameters=new FileMergerParameters();
  parameters.setIsNoDictionaryDimensionColumn(noDictionaryDimnesionColumn);
  parameters.setDimColCount(dimColCount);
  parameters.setComplexDimColCount(complexDimColCount);
  parameters.setMeasureColCount(measureColCount);
  parameters.setIntermediateFiles(intermediateFiles);
  parameters.setFileReadBufferSize(fileBufferSize);
  parameters.setFileWriteBufferSize(fileBufferSize);
  parameters.setOutFile(file);
  parameters.setCompressionEnabled(isSortFileCompressionEnabled);
  parameters.setNoOfRecordsInCompression(sortTempFileNoOFRecordsInCompression);
  parameters.setPrefetch(prefetch);
  parameters.setPrefetchBufferSize(bufferSize);
  parameters.setAggType(aggType);
  parameters.setNoDictionaryCount(noDictionaryCount);
  IntermediateFileMerger merger=new IntermediateFileMerger(parameters);
  executorService.submit(merger);
}

private void startIntermediateMerging ( File [ ] intermediateFiles ) { File file = new File ( this . tempFileLocation + File . separator + this . tableName + System . nanoTime ( ) + CarbonCommonConstants . MERGERD_EXTENSION ) ; FileMergerParameters parameters = new FileMergerParameters ( ) ; parameters . setIsNoDictionaryDimensionColumn ( noDictionaryDimnesionColumn ) ; parameters . setDimColCount ( dimColCount ) ; parameters . setComplexDimColCount ( complexDimColCount ) ; parameters . setMeasureColCount ( measureColCount ) ; parameters . setIntermediateFiles ( intermediateFiles ) ; parameters . setFileReadBufferSize ( fileBufferSize ) ; parameters . setFileWriteBufferSize ( fileBufferSize ) ; parameters . setOutFile ( file ) ; parameters . setCompressionEnabled ( isSortFileCompressionEnabled ) ; parameters . setNoOfRecordsInCompression ( sortTempFileNoOFRecordsInCompression ) ; parameters . setPrefetch ( prefetch ) ; parameters . setPrefetchBufferSize ( bufferSize ) ; parameters . setAggType ( aggType ) ; parameters . setNoDictionaryCount ( noDictionaryCount ) ; IntermediateFileMerger merger = new IntermediateFileMerger ( parameters ) ; executorService . submit ( merger ) ; }
below method will be used to start the intermediate file merging
