rtyler
03/16/2023, 2:30 AMSiva
03/16/2023, 3:51 PMc37
is a map type.rtyler
03/16/2023, 3:55 PMc37
field does look like what the MapBuilder
produces however.take()
call is being issued when it shouldn't betake
isn't implemented for MapArray
here: https://github.com/delta-io/delta-rs/blame/main/rust/src/writer/record_batch.rs#L400
Discussing this a bit elsewhere with @Christian Williams, and we definitely have workloads using maps with partition columns, so this must be a regression between the old writer code which #kafka-delta-ingest is using and the latest HEAD
of delta-rsJsonWriter
code behaves differently than the RecordBatchWriter
, 🤔