| 481 | |
| 482 | |
| 483 | bool ArrowReader::readNextBatchData() |
| 484 | { |
| 485 | |
| 486 | m_arrays.clear(); |
| 487 | for(int columnNum = 0; columnNum < m_currentBatch->num_columns(); ++columnNum) |
| 488 | { |
| 489 | // https://arrow.apache.org/docs/cpp/api/array.html#_CPPv4N5arrow5ArrayE |
| 490 | std::shared_ptr<arrow::Array> array = m_currentBatch->column(columnNum); |
| 491 | m_arrays[m_arrayIds[columnNum]] = array; |
| 492 | } |
| 493 | return true; |
| 494 | } |
| 495 | |
| 496 | bool ArrowReader::fillPoint(PointRef& point) |
| 497 | { |