| 184 | } |
| 185 | |
| 186 | Status ColumnArraysFromExecBatch(const ExecBatch& batch, int64_t start_row, |
| 187 | int64_t num_rows, |
| 188 | std::vector<KeyColumnArray>* column_arrays) { |
| 189 | int num_columns = static_cast<int>(batch.values.size()); |
| 190 | column_arrays->resize(num_columns); |
| 191 | for (int i = 0; i < num_columns; ++i) { |
| 192 | const Datum& data = batch.values[i]; |
| 193 | ARROW_DCHECK(data.is_array()); |
| 194 | const std::shared_ptr<ArrayData>& array_data = data.array(); |
| 195 | ARROW_ASSIGN_OR_RAISE((*column_arrays)[i], |
| 196 | ColumnArrayFromArrayData(array_data, start_row, num_rows)); |
| 197 | } |
| 198 | return Status::OK(); |
| 199 | } |
| 200 | |
| 201 | Status ColumnArraysFromExecBatch(const ExecBatch& batch, |
| 202 | std::vector<KeyColumnArray>* column_arrays) { |