| 231 | } |
| 232 | |
| 233 | Status ExampleLargeBatches(RecordBatchVector* out) { |
| 234 | const auto array_length = 32768; |
| 235 | std::shared_ptr<RecordBatch> batch; |
| 236 | std::vector<std::shared_ptr<arrow::Array>> arrays; |
| 237 | const auto arr = arrow::ConstantArrayGenerator::Float64(array_length, 1.0); |
| 238 | for (int i = 0; i < 128; i++) { |
| 239 | arrays.push_back(arr); |
| 240 | } |
| 241 | auto schema = ExampleLargeSchema(); |
| 242 | out->push_back(RecordBatch::Make(schema, array_length, arrays)); |
| 243 | out->push_back(RecordBatch::Make(schema, array_length, arrays)); |
| 244 | return Status::OK(); |
| 245 | } |
| 246 | |
| 247 | arrow::Result<std::shared_ptr<RecordBatch>> VeryLargeBatch() { |
| 248 | // In CI, some platforms don't let us allocate one very large |
no test coverage detected