Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit 3b4a94f

Browse files
author
Davies Liu
committed
DecimalType is not read back when non-native type exists
1 parent f7fe9e4 commit 3b4a94f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetConverter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ private[parquet] abstract class CatalystConverter extends GroupConverter {
244244
* Read a decimal value from a Parquet Binary into "dest". Only supports decimals that fit in
245245
* a long (i.e. precision <= 18)
246246
*/
247-
protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Unit = {
247+
protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Decimal = {
248248
val precision = ctype.precisionInfo.get.precision
249249
val scale = ctype.precisionInfo.get.scale
250250
val bytes = value.getBytes

0 commit comments

Comments
 (0)