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

Method decode

arrow-json/src/reader/mod.rs:472–474  ·  view source on GitHub ↗

Read JSON objects from `buf`, returning the number of bytes read This method returns once `batch_size` objects have been parsed since the last call to [`Self::flush`], or `buf` is exhausted. Any remaining bytes should be included in the next call to [`Self::decode`] There is no requirement that `buf` contains a whole number of records, facilitating integration with arbitrary byte streams, such a

(&mut self, buf: &[u8])

Source from the content-addressed store, hash-verified

470 /// There is no requirement that `buf` contains a whole number of records, facilitating
471 /// integration with arbitrary byte streams, such as those yielded by [`BufRead`]
472 pub fn decode(&mut self, buf: &[u8]) -> Result<usize, ArrowError> {
473 self.tape_decoder.decode(buf)
474 }
475
476 /// Serialize `rows` to this [`Decoder`]
477 ///

Callers 4

decode_and_flushFunction · 0.45
readMethod · 0.45
flushMethod · 0.45
test_decoder_errorFunction · 0.45

Calls

no outgoing calls

Tested by 1

test_decoder_errorFunction · 0.36