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

Function make_decoder

arrow-avro/src/reader/mod.rs:1578–1586  ·  view source on GitHub ↗
(store: &SchemaStore, fp: Fingerprint, reader_schema: &AvroSchema)

Source from the content-addressed store, hash-verified

1576 }
1577
1578 fn make_decoder(store: &SchemaStore, fp: Fingerprint, reader_schema: &AvroSchema) -> Decoder {
1579 ReaderBuilder::new()
1580 .with_batch_size(8)
1581 .with_reader_schema(reader_schema.clone())
1582 .with_writer_schema_store(store.clone())
1583 .with_active_fingerprint(fp)
1584 .build_decoder()
1585 .expect("decoder")
1586 }
1587
1588 fn make_id_prefix(id: u32, additional: usize) -> Vec<u8> {
1589 let capacity = CONFLUENT_MAGIC.len() + size_of::<u32>() + additional;

Calls 6

build_decoderMethod · 0.45
with_reader_schemaMethod · 0.45
with_batch_sizeMethod · 0.45
cloneMethod · 0.45