MCPcopy Create free account
hub / github.com/apache/arrow / DoFinish

Method DoFinish

cpp/src/arrow/dataset/dataset_writer.cc:255–265  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

253 }
254
255 Future<> DoFinish() {
256 {
257 std::lock_guard<std::mutex> lg(writer_state_->visitors_mutex);
258 RETURN_NOT_OK(options_.writer_pre_finish(writer_.get()));
259 }
260 return writer_->Finish().Then(
261 [self = shared_from_this(), writer_post_finish = options_.writer_post_finish]() {
262 std::lock_guard<std::mutex> lg(self->writer_state_->visitors_mutex);
263 return writer_post_finish(self->writer_.get());
264 });
265 }
266
267 const FileSystemDatasetWriteOptions& options_;
268 const std::shared_ptr<Schema>& schema_;

Callers 1

FinishMethod · 0.95

Calls 3

ThenMethod · 0.80
getMethod · 0.45
FinishMethod · 0.45

Tested by

no test coverage detected