We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f7fe9e4 commit 3b4a94fCopy full SHA for 3b4a94f
sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetConverter.scala
@@ -244,7 +244,7 @@ private[parquet] abstract class CatalystConverter extends GroupConverter {
244
* Read a decimal value from a Parquet Binary into "dest". Only supports decimals that fit in
245
* a long (i.e. precision <= 18)
246
*/
247
- protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Unit = {
+ protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Decimal = {
248
val precision = ctype.precisionInfo.get.precision
249
val scale = ctype.precisionInfo.get.scale
250
val bytes = value.getBytes
0 commit comments