MCPcopy Create free account
hub / github.com/apache/arrow / SelectiveIpcFileRecordBatchGenerator

Class SelectiveIpcFileRecordBatchGenerator

cpp/src/arrow/ipc/reader.cc:1342–1355  ·  view source on GitHub ↗

A generator of record batches for use when reading a subset of columns from the file. All batches are yielded in order.

Source from the content-addressed store, hash-verified

1340///
1341/// All batches are yielded in order.
1342class 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
1357class RecordBatchFileReaderImpl : public RecordBatchFileReader {
1358 public:

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected