processing/src/main/java/org/apache/carbondata/processing/loading/steps/DataConverterProcessorWithBucketingStepImpl.java
/**
   * Process the batch of rows as per the step logic.
   *
   * @param rowBatch
   * @return processed row.
   */
Process the batch of rows as per the step logic.
@param rowBatch
@return processed row.
Process the batch of rows as per the step logic . @param rowBatch @return processed row .
protected CarbonRowBatch processRowBatch(CarbonRowBatch rowBatch, RowConverter localConverter) {
    while (rowBatch.hasNext()) {
      CarbonRow row = rowBatch.next();
      short bucketNumber = (short) partitioner.getPartition(row.getData());
      CarbonRow convertRow = localConverter.convert(row);
      convertRow.bucketNumber = bucketNumber;
      rowBatch.setPreviousRow(convertRow);
    }
    rowCounter.getAndAdd(rowBatch.getSize());
    rowBatch.rewind();
    return rowBatch;
  }
protected CarbonRowBatch processRowBatch ( CarbonRowBatch rowBatch , RowConverter localConverter ) { while ( rowBatch . hasNext ( ) ) { CarbonRow row = rowBatch . next ( ) ; short bucketNumber = ( short ) partitioner . getPartition ( row . getData ( ) ) ; CarbonRow convertRow = localConverter . convert ( row ) ; convertRow . bucketNumber = bucketNumber ; rowBatch . setPreviousRow ( convertRow ) ; } rowCounter . getAndAdd ( rowBatch . getSize ( ) ) ; rowBatch . rewind ( ) ; return rowBatch ; }
Process the batch of rows as per the step logic.
Process the batch of rows as per the step logic .
// reuse the origin batch