| 47 | using ::arrow::json::ArrayFromJSONString; |
| 48 | |
| 49 | Result<std::shared_ptr<Buffer>> WriteRecordBatch( |
| 50 | const std::shared_ptr<RecordBatch>& batch, const WriteOptions& options) { |
| 51 | ARROW_ASSIGN_OR_RAISE(auto sink, io::BufferOutputStream::Create(1024)); |
| 52 | ARROW_ASSIGN_OR_RAISE(auto writer, MakeCSVWriter(sink.get(), batch->schema(), options)); |
| 53 | RETURN_NOT_OK(writer->WriteRecordBatch(*batch)); |
| 54 | RETURN_NOT_OK(writer->Close()); |
| 55 | return sink->Finish(); |
| 56 | } |
| 57 | |
| 58 | Result<std::shared_ptr<RecordBatch>> MakeBatch( |
| 59 | std::function<Result<std::shared_ptr<Array>>(int64_t length, double null_probability)> |
nothing calls this directly
no test coverage detected