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

Method ScanBatchesAsync

cpp/src/arrow/dataset/file_json.cc:379–384  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

377}
378
379Result<RecordBatchGenerator> JsonFileFormat::ScanBatchesAsync(
380 const std::shared_ptr<ScanOptions>& scan_options,
381 const std::shared_ptr<FileFragment>& file) const {
382 ARROW_ASSIGN_OR_RAISE(auto gen, MakeBatchGenerator(*this, scan_options, file));
383 return MakeChunkedBatchGenerator(std::move(gen), scan_options->batch_size);
384}
385
386Future<std::optional<int64_t>> JsonFileFormat::CountRows(
387 const std::shared_ptr<FileFragment>& file, compute::Expression predicate,

Callers

nothing calls this directly

Calls 1

Tested by

no test coverage detected