From af7ca2d7a5523b6be38d894bffe554b7d998d6f0 Mon Sep 17 00:00:00 2001 From: Nong Li Date: Thu, 10 Mar 2016 12:00:30 -0800 Subject: [PATCH] Update UnsafeRow to use API --- .../org/apache/spark/sql/catalyst/expressions/UnsafeRow.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java index a88bcbfdb7ccb..dd2f39eb816f2 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/UnsafeRow.java @@ -400,7 +400,7 @@ public Decimal getDecimal(int ordinal, int precision, int scale) { return null; } if (precision <= Decimal.MAX_LONG_DIGITS()) { - return Decimal.apply(getLong(ordinal), precision, scale); + return Decimal.createUnsafe(getLong(ordinal), precision, scale); } else { byte[] bytes = getBinary(ordinal); BigInteger bigInteger = new BigInteger(bytes);