Skip to content

Commit b4421f4

Browse files
committed
fix Decimal
1 parent 4fa81ac commit b4421f4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

rust/cubesql/cubesql/src/sql/dataframe.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)