| 287 | } |
| 288 | |
| 289 | void writeAndConvert(RemoteBlockOutputStream & remote, ReadBufferFromFile & in) |
| 290 | { |
| 291 | CompressedReadBuffer decompressing_in(in); |
| 292 | NativeBlockInputStream block_in(decompressing_in, DBMS_TCP_PROTOCOL_VERSION); |
| 293 | block_in.readPrefix(); |
| 294 | |
| 295 | while (Block block = block_in.read()) |
| 296 | { |
| 297 | ConvertingBlockInputStream convert( |
| 298 | std::make_shared<OneBlockInputStream>(block), |
| 299 | remote.getHeader(), |
| 300 | ConvertingBlockInputStream::MatchColumnsMode::Name); |
| 301 | auto adopted_block = convert.read(); |
| 302 | remote.write(adopted_block); |
| 303 | } |
| 304 | |
| 305 | block_in.readSuffix(); |
| 306 | } |
| 307 | |
| 308 | void writeRemoteConvert( |
| 309 | const DistributedHeader & distributed_header, |
no test coverage detected