Github user xubo245 commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2816#discussion_r228392301
  
    --- Diff: 
hadoop/src/main/java/org/apache/carbondata/hadoop/CarbonRecordReader.java ---
    @@ -116,6 +116,20 @@ public void initialize(InputSplit inputSplit, 
TaskAttemptContext context)
         return readSupport.readRow(carbonIterator.next());
       }
     
    +  /**
    +   * get batch result
    +   *
    +   * @param batch batch size
    +   * @return rows
    +   */
    +  public List<Object[]> getBatchValue(int batch) {
    +    rowCount += batch;
    --- End diff --
    
    ok, optimized


---

Reply via email to