| 746 | std::move(resume_callback), std::move(finish_callback), max_rows_queued)) {} |
| 747 | |
| 748 | Result<std::unique_ptr<DatasetWriter>> DatasetWriter::Make( |
| 749 | FileSystemDatasetWriteOptions write_options, util::AsyncTaskScheduler* scheduler, |
| 750 | std::function<void()> pause_callback, std::function<void()> resume_callback, |
| 751 | std::function<void()> finish_callback, uint64_t max_rows_queued) { |
| 752 | RETURN_NOT_OK(ValidateOptions(write_options)); |
| 753 | RETURN_NOT_OK(EnsureDestinationValid(write_options)); |
| 754 | return std::unique_ptr<DatasetWriter>(new DatasetWriter( |
| 755 | std::move(write_options), scheduler, std::move(pause_callback), |
| 756 | std::move(resume_callback), std::move(finish_callback), max_rows_queued)); |
| 757 | } |
| 758 | |
| 759 | DatasetWriter::~DatasetWriter() = default; |
| 760 |
nothing calls this directly
no test coverage detected