From 1114d71b8ea3b5ec8e52c7f4b5c74becb2635d3d Mon Sep 17 00:00:00 2001 From: Liangcai Li Date: Mon, 28 Oct 2024 14:29:26 +0800 Subject: [PATCH] Update sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala Co-authored-by: Renjie Liu --- .../scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala index ebc0b1cb8a5..e3b43d928f5 100644 --- a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala +++ b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala @@ -178,7 +178,7 @@ sealed trait TableOperator[T <: AutoCloseable, C] { def concatOnHost(tables: Array[T]): C } -class CudfTableOperator extends TableOperator[SerializedTableColumn, HostConcatResult] { +class JCudfTableOperator extends TableOperator[SerializedTableColumn, HostConcatResult] { override def getDataLen(table: SerializedTableColumn): Long = table.header.getDataLen override def getNumRows(table: SerializedTableColumn): Int = table.header.getNumRows