MCPcopy Create free account
hub / github.com/apache/paimon-rust / make_batch

Function make_batch

crates/paimon/src/table/table_write.rs:778–791  ·  view source on GitHub ↗
(ids: Vec<i32>, values: Vec<i32>)

Source from the content-addressed store, hash-verified

776 }
777
778 fn make_batch(ids: Vec<i32>, values: Vec<i32>) -> RecordBatch {
779 let schema = Arc::new(ArrowSchema::new(vec![
780 ArrowField::new("id", ArrowDataType::Int32, false),
781 ArrowField::new("value", ArrowDataType::Int32, false),
782 ]));
783 RecordBatch::try_new(
784 schema,
785 vec![
786 Arc::new(Int32Array::from(ids)),
787 Arc::new(Int32Array::from(values)),
788 ],
789 )
790 .unwrap()
791 }
792
793 fn make_partitioned_batch(pts: Vec<&str>, ids: Vec<i32>) -> RecordBatch {
794 let schema = Arc::new(ArrowSchema::new(vec![

Calls

no outgoing calls