| 400 | } |
| 401 | |
| 402 | Result<std::shared_ptr<RecordBatch>> RecordBatch::RenameColumns( |
| 403 | const std::vector<std::string>& names) const { |
| 404 | int n = num_columns(); |
| 405 | |
| 406 | if (static_cast<int>(names.size()) != n) { |
| 407 | return Status::Invalid("tried to rename a record batch of ", n, " columns but only ", |
| 408 | names.size(), " names were provided"); |
| 409 | } |
| 410 | |
| 411 | ArrayVector columns(n); |
| 412 | FieldVector fields(n); |
| 413 | |
| 414 | for (int i = 0; i < n; ++i) { |
| 415 | columns[i] = column(i); |
| 416 | fields[i] = schema()->field(i)->WithName(names[i]); |
| 417 | } |
| 418 | |
| 419 | return RecordBatch::Make(::arrow::schema(std::move(fields)), num_rows(), |
| 420 | std::move(columns), GetSyncEvent()); |
| 421 | } |
| 422 | |
| 423 | Result<std::shared_ptr<RecordBatch>> RecordBatch::SelectColumns( |
| 424 | const std::vector<int>& indices) const { |