| 19 | using namespace common; |
| 20 | |
| 21 | static uint64_t getArrowBatchLength(const ArrowArrayWrapper& array) { |
| 22 | if (array.length > 0) { |
| 23 | return array.length; |
| 24 | } |
| 25 | if (array.n_children > 0 && array.children && array.children[0]) { |
| 26 | return array.children[0]->length; |
| 27 | } |
| 28 | return 0; |
| 29 | } |
| 30 | |
| 31 | static int64_t findColumnIdx(const ArrowSchemaWrapper& schema, const std::string& colName) { |
| 32 | for (int64_t i = 0; i < schema.n_children; ++i) { |
no outgoing calls
no test coverage detected