| 55 | : ColumnBuilder(std::move(task_group)), pool_(pool), col_index_(col_index) {} |
| 56 | |
| 57 | void Append(const std::shared_ptr<BlockParser>& parser) override { |
| 58 | Insert(static_cast<int64_t>(chunks_.size()), parser); |
| 59 | } |
| 60 | |
| 61 | Result<std::shared_ptr<ChunkedArray>> Finish() override { |
| 62 | std::lock_guard<std::mutex> lock(mutex_); |