| 1186 | } |
| 1187 | |
| 1188 | Status WriteBatch(const std::shared_ptr<RecordBatch>& batch, |
| 1189 | const std::shared_ptr<const KeyValueMetadata>& metadata = nullptr) { |
| 1190 | RETURN_NOT_OK(writer_->WriteRecordBatch(*batch, metadata)); |
| 1191 | num_batches_written_++; |
| 1192 | return Status::OK(); |
| 1193 | } |
| 1194 | |
| 1195 | Status WriteTable(const RecordBatchVector& batches) { |
| 1196 | num_batches_written_ += static_cast<int>(batches.size()); |
no test coverage detected