| 261 | } |
| 262 | |
| 263 | void InferringColumnBuilder::ScheduleConvertChunk(int64_t chunk_index) { |
| 264 | task_group_->Append([self = shared_from_this(), this, chunk_index]() { |
| 265 | return TryConvertChunk(chunk_index); |
| 266 | }); |
| 267 | } |
| 268 | |
| 269 | Status InferringColumnBuilder::TryConvertChunk(int64_t chunk_index) { |
| 270 | std::unique_lock<std::mutex> lock(mutex_); |