Method FlushValues

cpp/src/parquet/encoder.cc:585–597

  }

  std::shared_ptr<Buffer> FlushValues() override {
    const int64_t buffer_size = EstimatedDataEncodedSize();
    if (buffer_size > std::numeric_limits<int>::max()) {
      std::stringstream ss;
      ss << "Buffer size for DictEncoder (" << buffer_size
         << ") exceeds maximum int value";
      throw ParquetException(ss.str());
    }
    std::shared_ptr<ResizableBuffer> buffer = AllocateBuffer(this->pool_, buffer_size);
    int result_size = WriteIndices(buffer->mutable_data(), static_cast<int>(buffer_size));
    PARQUET_THROW_NOT_OK(buffer->Resize(result_size, false));
    return buffer;
  }

  /// Writes out the encoded dictionary to buffer. buffer must be preallocated to
  /// dict_encoded_size() bytes.