-
Notifications
You must be signed in to change notification settings - Fork 232
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.
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
Support arithmetic operators on ANSI interval types #5020
Conversation
Signed-off-by: Chong Gao <res_life@163.com>
build |
TODO:
|
@res-life please target to branch-22.06. |
build |
Signed-off-by: Chong Gao <res_life@163.com>
build |
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/Spark33XShims.scala
Show resolved
Hide resolved
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/scala/com/nvidia/spark/rapids/TypeChecks.scala
Outdated
Show resolved
Hide resolved
Signed-off-by: Chong Gao <res_life@163.com>
build |
build |
LGTM |
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/Spark33XShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/Spark33XShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/scala/org/apache/spark/sql/rapids/arithmetic.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/scala/org/apache/spark/sql/rapids/arithmetic.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/Spark33XShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/330+/scala/com/nvidia/spark/rapids/shims/Spark33XShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/scala/org/apache/spark/sql/rapids/arithmetic.scala
Outdated
Show resolved
Hide resolved
CI failed due to: #5147 |
Spark supports reading/writing dataframes with ANSI intervals from/to parquet files from 330 And Pyspark supports DayTimeIntervalType from 330 Although these operators are from Spark320, we add GPU support into 330 for Pyspark test convenient purpose, is this ok? BTW: Pyspark does not support year-month interval currently. |
It's OK as long as the plugin consistently handles these types in Spark 3.2. We don't have to support a type Spark supports as long as we need to fallback to the CPU properly in those cases. However I do find it a little weird that we have all the necessary code to support interval types in the plugin but chose not to for Spark 3.2. Not having a nice way to test it helps explain the context for why we support interval types in 3.3 but not in 3.2. Thanks! |
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
build |
sql-plugin/src/main/311until330-all/scala/com/nvidia/spark/rapids/shims/GpuTypeShims.scala
Outdated
Show resolved
Hide resolved
build |
Check Markdown links failed: FILE: docs/spark-qualification-tool.md |
Markdown link failure is a known issue with downloads page updated to the not-quite-yet-released 22.04 artifacts. |
Contributes #4151
Support arithmetic operators on ANSI interval types(year month interval and day time interval)
Signed-off-by: Chong Gao res_life@163.com