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

Method NextBatch

cpp/src/parquet/arrow/reader.cc:115–123  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

113 virtual const std::shared_ptr<Field> field() = 0;
114
115 ::arrow::Status NextBatch(int64_t batch_size,
116 std::shared_ptr<::arrow::ChunkedArray>* out) final {
117 RETURN_NOT_OK(LoadBatch(batch_size));
118 RETURN_NOT_OK(BuildArray(batch_size, out));
119 for (int x = 0; x < (*out)->num_chunks(); x++) {
120 RETURN_NOT_OK((*out)->chunk(x)->Validate());
121 }
122 return Status::OK();
123 }
124
125 virtual ::arrow::Status LoadBatch(int64_t num_records) = 0;
126

Callers 6

ReadColumnMethod · 0.80
GetRecordBatchReaderMethod · 0.80
ReadSingleColumnFileMethod · 0.80
TYPED_TESTFunction · 0.80
TESTFunction · 0.80
TEST_PFunction · 0.80

Calls 5

LoadBatchFunction · 0.85
BuildArrayFunction · 0.85
OKFunction · 0.50
num_chunksMethod · 0.45
ValidateMethod · 0.45

Tested by 4

ReadSingleColumnFileMethod · 0.64
TYPED_TESTFunction · 0.64
TESTFunction · 0.64
TEST_PFunction · 0.64