Skip to content

[SPARK-30341][SQL] Overflow check for interval arithmetic operations #26995

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
yaooqinn wants to merge 20 commits into from
Closed

[SPARK-30341][SQL] Overflow check for interval arithmetic operations #26995

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
829cfe7
[SPARK-30341][SQL] Overflow check for interval arithmetic operations
yaooqinn Dec 24, 2019
516080c
override nullable, fix tests
yaooqinn Dec 24, 2019
67767c0
fix
yaooqinn Dec 24, 2019
7293377
fix tests
yaooqinn Dec 24, 2019
f100d88
use old overflow style
yaooqinn Dec 24, 2019
ba44c5a
workaround for avg
yaooqinn Dec 24, 2019
67645d4
divide 0 return null as other types
yaooqinn Dec 24, 2019
7671d83
fix tests
yaooqinn Dec 24, 2019
b679381
name with exact
yaooqinn Dec 27, 2019
a8d29b6
rm try-catch
yaooqinn Dec 27, 2019
c3a8531
Merge branch 'master' into SPARK-30341
yaooqinn Dec 30, 2019
ccb1fd5
regen g f
yaooqinn Dec 30, 2019
d704c74
..Exact for ansi off
yaooqinn Dec 30, 2019
512570e
regen g f
yaooqinn Dec 30, 2019
5651959
import
yaooqinn Dec 30, 2019
92e2668
clean up
yaooqinn Dec 31, 2019
aba10b2
address comments
yaooqinn Jan 2, 2020
e37caaf
unify
yaooqinn Jan 2, 2020
988b51c
blank lines
yaooqinn Jan 2, 2020
f80f0f3
refine tests
yaooqinn Jan 2, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
blank lines
  • Loading branch information
@yaooqinn
yaooqinn committed Jan 2, 2020
commit 988b51c27fcc32ebfa8e8379ac4ae2913626c66d
2 changes: 0 additions & 2 deletions ...talyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/intervalExpressions.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -116,12 +116,10 @@ abstract class IntervalNumOperation(
operation: (CalendarInterval, Double) => CalendarInterval,
operationName: String)
extends BinaryExpression with ImplicitCastInputTypes with Serializable {

override def left: Expression = interval
override def right: Expression = num

override def inputTypes: Seq[AbstractDataType] = Seq(CalendarIntervalType, DoubleType)

override def dataType: DataType = CalendarIntervalType

override def nullable: Boolean = true
Expand Down
1 change: 0 additions & 1 deletion sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/IntervalUtils.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -438,7 +438,6 @@ object IntervalUtils {
* Return a new calendar interval instance of the sum of two intervals.
*
* @throws ArithmeticException if the result overflows any field value
*
*/
def addExact(left: CalendarInterval, right: CalendarInterval): CalendarInterval = {
val months = Math.addExact(left.months, right.months)
Expand Down