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

Method ScanBatchesAsync

cpp/src/arrow/dataset/file_test.cc:110–119  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

108 MockFileFormat() : FileFormat(/*default_fragment_scan_options=*/nullptr) {}
109
110 Result<RecordBatchGenerator> ScanBatchesAsync(
111 const std::shared_ptr<ScanOptions>& options,
112 const std::shared_ptr<FileFragment>& file) const override {
113 auto sch = schema({field("i32", int32())});
114 RecordBatchVector batches;
115 for (int i = 0; i < kNumBatches; i++) {
116 batches.push_back(ConstantArrayGenerator::Zeroes(kRowsPerBatch, sch));
117 }
118 return MakeVectorGenerator(std::move(batches));
119 }
120
121 protected:
122 std::string type_name() const override { return "mock"; }

Callers

nothing calls this directly

Calls 4

MakeVectorGeneratorFunction · 0.85
push_backMethod · 0.80
schemaFunction · 0.50
fieldFunction · 0.50

Tested by

no test coverage detected