File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -307,7 +307,14 @@ final class SpecificMutableRow(val values: Array[MutableValue]) extends MutableR
307
307
values(i).asInstanceOf [MutableByte ].value
308
308
}
309
309
310
- override def getAs [T ](i : Int ): T = {
311
- values(i).asInstanceOf [MutableAny ].value.asInstanceOf [T ]
310
+ override def getAs [T ](i : Int ): T = values(i) match {
311
+ case r : MutableInt => r.value.asInstanceOf [T ]
312
+ case r : MutableByte => r.value.asInstanceOf [T ]
313
+ case r : MutableFloat => r.value.asInstanceOf [T ]
314
+ case r : MutableShort => r.value.asInstanceOf [T ]
315
+ case r : MutableDouble => r.value.asInstanceOf [T ]
316
+ case r : MutableBoolean => r.value.asInstanceOf [T ]
317
+ case r : MutableLong => r.value.asInstanceOf [T ]
318
+ case r => r.asInstanceOf [MutableAny ].value.asInstanceOf [T ]
312
319
}
313
320
}
You can’t perform that action at this time.
0 commit comments