Skip to content

Commit 48cc57c

Browse files
author
Davies Liu
committed
Update ParquetConverter.scala
1 parent b43845c commit 48cc57c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -243,6 +243,8 @@ private[parquet] abstract class CatalystConverter extends GroupConverter {
243243
/**
244244
* Read a decimal value from a Parquet Binary into "dest". Only supports decimals that fit in
245245
* a long (i.e. precision <= 18)
246+
*
247+
* Returned value is needed by CatalystConverter, which doesn't reuse the Decimal object.
246248
*/
247249
protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Decimal = {
248250
val precision = ctype.precisionInfo.get.precision

0 commit comments

Comments
 (0)