Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.11.1
Description
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
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()?;
I was wondering if I could do something like:
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()?;
==================================
Attachments
Issue Links
- links to