| 808 | class SimpleRecordBatchReader : public RecordBatchReader { |
| 809 | public: |
| 810 | SimpleRecordBatchReader(Iterator<std::shared_ptr<RecordBatch>> it, |
| 811 | std::shared_ptr<Schema> schema, |
| 812 | DeviceAllocationType device_type = DeviceAllocationType::kCPU) |
| 813 | : schema_(std::move(schema)), it_(std::move(it)), device_type_(device_type) {} |
| 814 | |
| 815 | SimpleRecordBatchReader(std::vector<std::shared_ptr<RecordBatch>> batches, |
| 816 | std::shared_ptr<Schema> schema, |
nothing calls this directly
no test coverage detected