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

Method next_batch

parquet/src/arrow/array_reader/mod.rs:99–102  ·  view source on GitHub ↗
(&mut self, batch_size: usize)

Source from the content-addressed store, hash-verified

97 /// Reads at most `batch_size` records into an arrow array and return it.
98 #[cfg(any(feature = "experimental", test))]
99 fn next_batch(&mut self, batch_size: usize) -> Result<ArrayRef> {
100 self.read_records(batch_size)?;
101 self.consume_batch()
102 }
103
104 /// Reads at most `batch_size` records' bytes into buffer
105 ///

Implementers 15

empty_array.rsparquet/src/arrow/array_reader/empty_a
row_number.rsparquet/src/arrow/array_reader/row_num
primitive_array.rsparquet/src/arrow/array_reader/primiti
byte_view_array.rsparquet/src/arrow/array_reader/byte_vi
byte_array_dictionary.rsparquet/src/arrow/array_reader/byte_ar
byte_array.rsparquet/src/arrow/array_reader/byte_ar
list_view_array.rsparquet/src/arrow/array_reader/list_vi
fixed_len_byte_array.rsparquet/src/arrow/array_reader/fixed_l
map_array.rsparquet/src/arrow/array_reader/map_arr
struct_array.rsparquet/src/arrow/array_reader/struct_
list_array.rsparquet/src/arrow/array_reader/list_ar
null_array.rsparquet/src/arrow/array_reader/null_ar

Calls 2

read_recordsMethod · 0.45
consume_batchMethod · 0.45