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

Method consume_batch

parquet/src/arrow/array_reader/byte_view_array.rs:108–118  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

106 }
107
108 fn consume_batch(&mut self) -> Result<ArrayRef> {
109 let buffer = self.record_reader.consume_record_data();
110 let null_buffer = self.record_reader.consume_bitmap_buffer();
111 self.def_levels_buffer = self.record_reader.consume_def_levels();
112 self.rep_levels_buffer = self.record_reader.consume_rep_levels();
113 self.record_reader.reset();
114
115 let array = buffer.into_array(null_buffer, &self.data_type);
116
117 Ok(array)
118 }
119
120 fn skip_records(&mut self, num_records: usize) -> Result<usize> {
121 skip_records(&mut self.record_reader, self.pages.as_mut(), num_records)

Callers

nothing calls this directly

Calls 6

consume_record_dataMethod · 0.80
consume_bitmap_bufferMethod · 0.80
consume_def_levelsMethod · 0.80
consume_rep_levelsMethod · 0.80
resetMethod · 0.45
into_arrayMethod · 0.45

Tested by

no test coverage detected