Martin Tzvetanov Grigorov created AVRO-3630:
-----------------------------------------------

             Summary: [Rust] Make it possible to extend pre-existing Avro bytes
                 Key: AVRO-3630
                 URL: https://issues.apache.org/jira/browse/AVRO-3630
             Project: Apache Avro
          Issue Type: Improvement
          Components: rust
    Affects Versions: 1.11.1
            Reporter: Martin Tzvetanov Grigorov
            Assignee: Martin Tzvetanov Grigorov


>From ASF Slack 
>#[avro|[https://the-asf.slack.com/archives/CLUD54M1S/p1663751850569319]:]

===================================

 I'm currenlty solving it by reading the original file and appending it to a 
new Vec 
{code:java}
let bytes: Vec<u8> = object_store
                                .get(&old_manifest_location)
                                .await?
                                .bytes()
                                .await?
                                .into();

let mut writer = apache_avro::Writer::new(&schema, Vec::new());

let reader = apache_avro::Reader::new(&*bytes)?;
writer.extend(reader.filter_map(Result::ok))?;

writer.append_ser(entry)?;
let new_bytes = writer.into_inner()?;
{code}

I was wondering if I could do something like:
{code:java}
let bytes: Vec<u8> = object_store
                                .get(&old_manifest_location)
                                .await?
                                .bytes()
                                .await?
                                .into();

let mut writer = apache_avro::Writer::new(&schema, bytes);

writer.append_ser(entry)?;

let new_bytes = writer.into_inner()?;
{code}
==================================



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to