File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
v0.12.0/src/main/scala/org/apache/spark/sql/hive/thriftserver
v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -123,7 +123,7 @@ private[hive] class SparkExecuteStatementOperation(
123123 to.addColumnValue(ColumnValue .doubleValue(from.getDouble(ordinal)))
124124 case FloatType =>
125125 to.addColumnValue(ColumnValue .floatValue(from.getFloat(ordinal)))
126- case DecimalType =>
126+ case DecimalType () =>
127127 val hiveDecimal = from.get(ordinal).asInstanceOf [BigDecimal ].bigDecimal
128128 to.addColumnValue(ColumnValue .stringValue(new HiveDecimal (hiveDecimal)))
129129 case LongType =>
@@ -156,7 +156,7 @@ private[hive] class SparkExecuteStatementOperation(
156156 to.addColumnValue(ColumnValue .doubleValue(null ))
157157 case FloatType =>
158158 to.addColumnValue(ColumnValue .floatValue(null ))
159- case DecimalType =>
159+ case DecimalType () =>
160160 to.addColumnValue(ColumnValue .stringValue(null : HiveDecimal ))
161161 case LongType =>
162162 to.addColumnValue(ColumnValue .longValue(null ))
Original file line number Diff line number Diff line change @@ -123,7 +123,7 @@ private[hive] class SparkExecuteStatementOperation(
123123 to += from.getDouble(ordinal)
124124 case FloatType =>
125125 to += from.getFloat(ordinal)
126- case DecimalType =>
126+ case DecimalType () =>
127127 to += from.get(ordinal).asInstanceOf [BigDecimal ].bigDecimal
128128 case LongType =>
129129 to += from.getLong(ordinal)
You can’t perform that action at this time.
0 commit comments