| 78 | } |
| 79 | |
| 80 | void CopyRelBatchInsert::writeToTable(RelBatchInsertExecutionState& executionState, |
| 81 | const storage::InMemChunkedCSRHeader&, const RelBatchInsertLocalState& localState, |
| 82 | BatchInsertSharedState& sharedState, const RelBatchInsertInfo& relInfo) { |
| 83 | auto& copyRelExecutionState = executionState.cast<CopyRelBatchInsertExecutionState>(); |
| 84 | for (auto& chunkedGroup : copyRelExecutionState.partitioningBuffer->getChunkedGroups()) { |
| 85 | sharedState.incrementNumRows(chunkedGroup->getNumRows()); |
| 86 | // we reused the bound node offset column to store row idx |
| 87 | // the row idx column determines which rows to write each entry in the chunked group to |
| 88 | localState.chunkedGroup->write(*chunkedGroup, relInfo.boundNodeOffsetColumnID); |
| 89 | } |
| 90 | } |
| 91 | } // namespace processor |
| 92 | } // namespace lbug |
no test coverage detected