| 167 | } |
| 168 | |
| 169 | std::vector<int64_t> ArrowNodeTable::getOutputToArrowColumnIdx( |
| 170 | const std::vector<common::column_id_t>& columnIDs) const { |
| 171 | std::vector<int64_t> outputToArrowColumnIdx(columnIDs.size(), -1); |
| 172 | for (size_t col = 0; col < columnIDs.size(); ++col) { |
| 173 | const auto columnID = columnIDs[col]; |
| 174 | if (columnID == common::INVALID_COLUMN_ID || columnID == common::ROW_IDX_COLUMN_ID) { |
| 175 | continue; |
| 176 | } |
| 177 | for (common::idx_t propIdx = 0; propIdx < nodeTableCatalogEntry->getNumProperties(); |
| 178 | ++propIdx) { |
| 179 | if (nodeTableCatalogEntry->getColumnID(propIdx) == columnID) { |
| 180 | outputToArrowColumnIdx[col] = static_cast<int64_t>(propIdx); |
| 181 | break; |
| 182 | } |
| 183 | } |
| 184 | } |
| 185 | return outputToArrowColumnIdx; |
| 186 | } |
| 187 | |
| 188 | void ArrowNodeTable::copyArrowMorselToOutputVectors(const ArrowArrayWrapper& batch, |
| 189 | const size_t currentMorselStartOffset, const uint64_t numRowsToCopy, |
nothing calls this directly
no test coverage detected