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

Method FromRecordBatchReader

cpp/src/arrow/dataset/scanner.cc:902–909  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

900 std::move(scan_options)) {}
901
902std::shared_ptr<ScannerBuilder> ScannerBuilder::FromRecordBatchReader(
903 std::shared_ptr<RecordBatchReader> reader) {
904 auto batch_it = MakeIteratorFromReader(reader);
905 auto fragment =
906 std::make_shared<OneShotFragment>(reader->schema(), std::move(batch_it));
907 return std::make_shared<ScannerBuilder>(reader->schema(), std::move(fragment),
908 std::make_shared<ScanOptions>());
909}
910
911const std::shared_ptr<Schema>& ScannerBuilder::schema() const {
912 return scan_options_->dataset_schema;

Callers

nothing calls this directly

Calls 2

MakeIteratorFromReaderFunction · 0.85
schemaMethod · 0.45

Tested by

no test coverage detected