File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -454,7 +454,8 @@ impl ColumnInfo {
454454 | DataType :: UInt8
455455 | DataType :: UInt16
456456 | DataType :: UInt32
457- | DataType :: UInt64 => {
457+ | DataType :: UInt64
458+ | DataType :: Float32 => {
458459 column_info. r#type = "fixed" . to_string ( ) ;
459460 column_info. precision = Some ( 38 ) ;
460461 column_info. scale = Some ( 0 ) ;
Original file line number Diff line number Diff line change @@ -73,8 +73,6 @@ pub fn convert_record_batches(
7373 columns. push ( converted_column) ;
7474 }
7575 let new_schema = Arc :: new ( Schema :: new ( fields) ) ;
76- //println!("new schema: {:?}", new_schema);
77- //println!("columns: {:?}", columns);
7876 let converted_batch = RecordBatch :: try_new ( new_schema, columns) ?;
7977 converted_batches. push ( converted_batch) ;
8078 }
You can’t perform that action at this time.
0 commit comments