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