From 5ec4586d9bbb420bf7dc728555d629350a263a61 Mon Sep 17 00:00:00 2001 From: Liangcai Li Date: Mon, 28 Oct 2024 14:29:35 +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 e3b43d928f5..79cdae5444e 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 @@ -172,7 +172,7 @@ object GpuShuffleCoalesceUtils { * This is used by HostCoalesceIteratorBase to separate the table operations from * the shuffle read process. */ -sealed trait TableOperator[T <: AutoCloseable, C] { +sealed trait SerializedTableOperator[T <: AutoCloseable, C] { def getDataLen(table: T): Long def getNumRows(table: T): Int def concatOnHost(tables: Array[T]): C