Function flushToManyFiles

src/Interpreters/SortedBlocksWriter.cpp:49–66

}

SortedBlocksWriter::SortedFiles flushToManyFiles(const TemporaryDataOnDiskScopePtr & tmp_data, QueryPipelineBuilder builder,
                                                 std::function<void(const Block &)> callback)
{
    SortedBlocksWriter::SortedFiles files;
    auto pipeline = QueryPipelineBuilder::getPipeline(std::move(builder));
    PullingPipelineExecutor executor(pipeline);

    Block block;
    while (executor.pull(block))
    {
        if (!block.rows())
            continue;
        callback(block);
        files.push_back(flushBlockToFile(tmp_data, block));
    }

    return files;
}

}