@@ -417,7 +417,7 @@ pub fn arrow_to_column_type(arrow_type: DataType) -> Result<ColumnType, CubeErro
417417 | DataType :: Int32 => Ok ( ColumnType :: Int32 ) ,
418418 DataType :: UInt32
419419 | DataType :: Int64 => Ok ( ColumnType :: Int64 ) ,
420- DataType :: UInt64 => Ok ( ColumnType :: Decimal ( 128 , 0 ) ) ,
420+ DataType :: UInt64 => Ok ( ColumnType :: Decimal ( 39 , 0 ) ) ,
421421 DataType :: Null => Ok ( ColumnType :: String ) ,
422422 x => Err ( CubeError :: internal ( format ! ( "unsupported type {:?}" , x) ) ) ,
423423 }
@@ -844,7 +844,7 @@ mod tests {
844844 ( DataType :: Int32 , ColumnType :: Int32 ) ,
845845 ( DataType :: UInt32 , ColumnType :: Int64 ) ,
846846 ( DataType :: Int64 , ColumnType :: Int64 ) ,
847- ( DataType :: UInt64 , ColumnType :: Decimal ( 128 , 0 ) ) ,
847+ ( DataType :: UInt64 , ColumnType :: Decimal ( 39 , 0 ) ) ,
848848 ( DataType :: Null , ColumnType :: String ) ,
849849 ] ;
850850
@@ -1018,7 +1018,7 @@ mod tests {
10181018 create_record_batch (
10191019 DataType :: UInt64 ,
10201020 UInt64Array :: from ( data64. clone ( ) ) ,
1021- ColumnType :: Decimal ( 128 , 0 ) ,
1021+ ColumnType :: Decimal ( 39 , 0 ) ,
10221022 data64
10231023 . into_iter ( )
10241024 . map ( |e| TableValue :: Decimal128 ( Decimal128Value :: new ( e as i128 , 0 ) ) )
0 commit comments