| 205 | } |
| 206 | |
| 207 | static void appendStorageInfoForNodeGroup(StorageInfoLocalState* localState, DataChunk& outputChunk, |
| 208 | StorageInfoOutputData& outputData, NodeGroup* nodeGroup) { |
| 209 | auto numChunks = nodeGroup->getNumChunkedGroups(); |
| 210 | for (auto chunkIdx = 0ul; chunkIdx < numChunks; chunkIdx++) { |
| 211 | outputData.chunkIdx = chunkIdx; |
| 212 | appendStorageInfoForChunkedGroup(localState, outputChunk, outputData, |
| 213 | nodeGroup->getChunkedNodeGroup(chunkIdx)); |
| 214 | } |
| 215 | if (nodeGroup->getFormat() == NodeGroupDataFormat::CSR) { |
| 216 | auto& csrNodeGroup = nodeGroup->cast<CSRNodeGroup>(); |
| 217 | auto persistentChunk = csrNodeGroup.getPersistentChunkedGroup(); |
| 218 | if (persistentChunk) { |
| 219 | outputData.chunkIdx = INVALID_NODE_GROUP_IDX; |
| 220 | appendStorageInfoForChunkedGroup(localState, outputChunk, outputData, |
| 221 | csrNodeGroup.getPersistentChunkedGroup()); |
| 222 | } |
| 223 | } |
| 224 | } |
| 225 | |
| 226 | static void appendStorageInfoForIndex(StorageInfoLocalState* localState, DataChunk& outputChunk, |
| 227 | const Index& index) { |
no test coverage detected