MCPcopy Create free account
hub / github.com/apache/arrow-rs / skip_records

Method skip_records

parquet/src/arrow/array_reader/cached_array_reader.rs:259–268  ·  view source on GitHub ↗
(&mut self, num_records: usize)

Source from the content-addressed store, hash-verified

257 }
258
259 fn skip_records(&mut self, num_records: usize) -> Result<usize> {
260 let mut skipped = 0;
261 while skipped < num_records {
262 let size = std::cmp::min(num_records - skipped, self.batch_size);
263 skipped += size;
264 self.selections.append_n(size, false);
265 self.outer_position += size;
266 }
267 Ok(num_records)
268 }
269
270 fn consume_batch(&mut self) -> Result<ArrayRef> {
271 let row_count = self.selections.len();

Callers 2

fetch_batchMethod · 0.45
test_read_skip_patternFunction · 0.45

Calls 3

minFunction · 0.85
append_nMethod · 0.45
lenMethod · 0.45

Tested by 1

test_read_skip_patternFunction · 0.36