| 254 | } |
| 255 | |
| 256 | static void combineFunc(ExportFuncSharedState& sharedState, ExportFuncLocalState& localState) { |
| 257 | auto& serializer = localState.cast<ExportCSVLocalState>().serializer; |
| 258 | auto& exportCSVSharedState = sharedState.cast<ExportCSVSharedState>(); |
| 259 | if (serializer->getSize() > 0) { |
| 260 | exportCSVSharedState.writeRows(serializer->getBlobData(), serializer->getSize()); |
| 261 | serializer->clear(); |
| 262 | } |
| 263 | } |
| 264 | |
| 265 | static void finalizeFunc(ExportFuncSharedState&) {} |
| 266 |
no test coverage detected