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