| 637 | |
| 638 | |
| 639 | void DistributedBlockOutputStream::writeToLocal(const Block & block, size_t repeats) |
| 640 | { |
| 641 | InterpreterInsertQuery interp(query_ast, context, allow_materialized); |
| 642 | |
| 643 | auto block_io = interp.execute(); |
| 644 | |
| 645 | block_io.out->writePrefix(); |
| 646 | writeBlockConvert(block_io.out, block, repeats, log); |
| 647 | block_io.out->writeSuffix(); |
| 648 | } |
| 649 | |
| 650 | |
| 651 | void DistributedBlockOutputStream::writeToShard(const Block & block, const std::vector<std::string> & dir_names) |
nothing calls this directly
no test coverage detected