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

Class SelectiveIpcFileRecordBatchGenerator

cpp/src/arrow/ipc/reader.cc:1347–1360  ·  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

1345///
1346/// All batches are yielded in order.
1347class 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
1362class RecordBatchFileReaderImpl : public RecordBatchFileReader {
1363 public:

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected