add error utils for 3.1 and 3.2

Signed-off-by: remzi <13716567376yh@gmail.com>
NVIDIA · Jul 20, 2022 · a9b052b · a9b052b
1 parent 5a322b2
commit a9b052b
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 0 deletions.
diff --git a/...src/main/311until320-nondb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala b/...src/main/311until320-nondb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala
@@ -60,4 +60,8 @@ object RapidsErrorUtils {
     new ArithmeticException(s"${value.toDebugString} cannot be represented as " +
       s"Decimal(${toType.precision}, ${toType.scale}).")
   }
+
+  def overflowInIntegralDivideError(context: String = ""): ArithmeticException = {
+    new ArithmeticException("Overflow in integral divide.")
+  }
 }
diff --git a/sql-plugin/src/main/31xdb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala b/sql-plugin/src/main/31xdb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala
@@ -60,4 +60,8 @@ object RapidsErrorUtils {
     new ArithmeticException(s"${value.toDebugString} cannot be represented as " +
       s"Decimal(${toType.precision}, ${toType.scale}).")
   }
+
+  def overflowInIntegralDivideError(context: String = ""): ArithmeticException = {
+    new ArithmeticException("Overflow in integral divide.")
+  }
 }
diff --git a/...src/main/320until330-nondb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala b/...src/main/320until330-nondb/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala
@@ -62,5 +62,9 @@ object RapidsErrorUtils {
       value, toType.precision, toType.scale
     )
   }
+
+  def overflowInIntegralDivideError(context: String = ""): ArithmeticException = {
+    QueryExecutionErrors.overflowInIntegralDivideError()
+  }
 }
 
diff --git a/sql-plugin/src/main/321db/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala b/sql-plugin/src/main/321db/scala/org/apache/spark/sql/rapids/shims/RapidsErrorUtils.scala
@@ -65,4 +65,8 @@ object RapidsErrorUtils {
       value, toType.precision, toType.scale
     )
   }
+
+  def overflowInIntegralDivideError(context: String = ""): ArithmeticException = {
+    QueryExecutionErrors.overflowInIntegralDivideError()
+  }
 }