A generator of record batches for use when reading a subset of columns from the file. All batches are yielded in order.
| 1340 | /// |
| 1341 | /// All batches are yielded in order. |
| 1342 | class SelectiveIpcFileRecordBatchGenerator { |
| 1343 | public: |
| 1344 | using Item = std::shared_ptr<RecordBatch>; |
| 1345 | |
| 1346 | explicit SelectiveIpcFileRecordBatchGenerator( |
| 1347 | std::shared_ptr<RecordBatchFileReaderImpl> state) |
| 1348 | : state_(std::move(state)), index_(0) {} |
| 1349 | |
| 1350 | Future<Item> operator()(); |
| 1351 | |
| 1352 | private: |
| 1353 | std::shared_ptr<RecordBatchFileReaderImpl> state_; |
| 1354 | int index_; |
| 1355 | }; |
| 1356 | |
| 1357 | class RecordBatchFileReaderImpl : public RecordBatchFileReader { |
| 1358 | public: |
no outgoing calls
no test coverage detected