| 119 | Block getHeader() const override { return storage_snapshot->metadata->getSampleBlock(); } |
| 120 | |
| 121 | void write(const Block & block) override |
| 122 | { |
| 123 | storage_snapshot->metadata->check(block, true); |
| 124 | |
| 125 | auto flatten_block = block.cloneWithColumns(block.getColumns()); |
| 126 | if (!storage_snapshot->object_columns.empty()) |
| 127 | { |
| 128 | convertDynamicColumnsToTuples(flatten_block, storage_snapshot); |
| 129 | } |
| 130 | |
| 131 | if (storage.compress) |
| 132 | { |
| 133 | Block compressed_block; |
| 134 | for (const auto & elem : flatten_block) |
| 135 | compressed_block.insert({ elem.column->compress(), elem.type, elem.name }); |
| 136 | |
| 137 | new_blocks.emplace_back(compressed_block); |
| 138 | } |
| 139 | else |
| 140 | { |
| 141 | new_blocks.emplace_back(flatten_block); |
| 142 | } |
| 143 | } |
| 144 | |
| 145 | void writeSuffix() override |
| 146 | { |
nothing calls this directly
no test coverage detected