| 741 | } |
| 742 | |
| 743 | void writeToFile( |
| 744 | const std::string& path, |
| 745 | const VectorPtr& vector, |
| 746 | memory::MemoryPool* pool) { |
| 747 | dwrf::WriterOptions options; |
| 748 | options.schema = vector->type(); |
| 749 | options.memoryPool = pool; |
| 750 | auto writeFile = std::make_unique<LocalWriteFile>(path, true, false); |
| 751 | auto sink = |
| 752 | std::make_unique<dwio::common::WriteFileSink>(std::move(writeFile), path); |
| 753 | dwrf::Writer writer(std::move(sink), options); |
| 754 | writer.write(vector); |
| 755 | writer.close(); |
| 756 | } |
| 757 | |
| 758 | // static |
| 759 | std::shared_ptr<connector::ConnectorSplit> JoinFuzzer::makeSplit( |
no test coverage detected