MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / read

Method read

src/arrow-util/src/reader.rs:100–106  ·  view source on GitHub ↗

Read the value at `idx` into the provided `Row`.

(&self, idx: usize, row: &mut Row)

Source from the content-addressed store, hash-verified

98
99 /// Read the value at `idx` into the provided `Row`.
100 pub fn read(&self, idx: usize, row: &mut Row) -> Result<(), anyhow::Error> {
101 let mut packer = row.packer();
102 for reader in &self.readers {
103 reader.read(idx, &mut packer).context(idx)?;
104 }
105 Ok(())
106 }
107
108 /// Read all of the values in this [`ArrowReader`] into `rows`.
109 pub fn read_all(&self, rows: &mut Vec<Row>) -> Result<usize, anyhow::Error> {

Callers 15

_read_gcs_avroFunction · 0.45
_verify_sink_committedFunction · 0.45
_paginated_getFunction · 0.45
_polaris_getFunction · 0.45
workflow_commit_conflictFunction · 0.45
_terraform_apply_gcpFunction · 0.45
validate_uploadFunction · 0.45
loadMethod · 0.45
connection_pool_ttlMethod · 0.45

Calls 15

rescaleFunction · 0.85
StringClass · 0.85
packerMethod · 0.80
expectMethod · 0.80
divMethod · 0.80
unpack_firstMethod · 0.80
pack_strMethod · 0.80
saturating_mulMethod · 0.80
push_list_withMethod · 0.80
push_dict_withMethod · 0.80
push_rangeMethod · 0.80
NumericClass · 0.50

Tested by 15

auth_with_ws_implFunction · 0.36
test_http_sqlFunction · 0.36
test_max_request_sizeFunction · 0.36
test_ws_passes_optionsFunction · 0.36
test_internal_ws_authFunction · 0.36
test_cancel_wsFunction · 0.36
test_github_20262Function · 0.36
test_double_encoded_jsonFunction · 0.36
assert_success_responseFunction · 0.36