Function fillDecimalValues

tools/src/CSVFileImport.cc:128–168

parse fixed point decimal numbers

// parse fixed point decimal numbers
void fillDecimalValues(const std::vector<std::string>& data, orc::ColumnVectorBatch* batch,
                       uint64_t numValues, uint64_t colIndex, size_t scale, size_t precision) {
  orc::Decimal128VectorBatch* d128Batch = nullptr;
  orc::Decimal64VectorBatch* d64Batch = nullptr;
  if (precision <= 18) {
    d64Batch = dynamic_cast<orc::Decimal64VectorBatch*>(batch);
    d64Batch->scale = static_cast<int32_t>(scale);
  } else {
    d128Batch = dynamic_cast<orc::Decimal128VectorBatch*>(batch);
    d128Batch->scale = static_cast<int32_t>(scale);
  }
  bool hasNull = false;
  for (uint64_t i = 0; i < numValues; ++i) {
    std::string col = extractColumn(data[i], colIndex);
    if (col.empty()) {
      batch->notNull[i] = 0;
      hasNull = true;
    } else {
      batch->notNull[i] = 1;
      size_t ptPos = col.find('.');
      size_t curScale = 0;
      std::string num = col;
      if (ptPos != std::string::npos) {
        curScale = col.length() - ptPos - 1;
        num = col.substr(0, ptPos) + col.substr(ptPos + 1);
      }
      orc::Int128 decimal(num);
      while (curScale != scale) {
        curScale++;
        decimal *= 10;
      }
      if (precision <= 18) {
        d64Batch->values[i] = decimal.toLong();
      } else {
        d128Batch->values[i] = decimal;
      }
    }
  }
  batch->hasNulls = hasNull;
  batch->numElements = numValues;
}

void fillBoolValues(const std::vector<std::string>& data, orc::ColumnVectorBatch* batch,
                    uint64_t numValues, uint64_t colIndex) {