This is an automated email from the ASF dual-hosted git repository.
chengchengjin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 3b1903977f [MINOR][CORE] Remove unused class
DummyPairRDDWithPartitions (#10931)
3b1903977f is described below
commit 3b1903977f05833c828f2b5655ca641a43592f04
Author: Jin Chengcheng <[email protected]>
AuthorDate: Tue Oct 28 09:58:00 2025 +0000
[MINOR][CORE] Remove unused class DummyPairRDDWithPartitions (#10931)
---
.../spark/sql/execution/ColumnarShuffleExchangeExec.scala | 13 -------------
1 file changed, 13 deletions(-)
diff --git
a/gluten-substrait/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
b/gluten-substrait/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
index 113097b816..055b943392 100644
---
a/gluten-substrait/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
+++
b/gluten-substrait/src/main/scala/org/apache/spark/sql/execution/ColumnarShuffleExchangeExec.scala
@@ -32,7 +32,6 @@ import org.apache.spark.sql.catalyst.expressions.Attribute
import org.apache.spark.sql.catalyst.plans.logical.Statistics
import org.apache.spark.sql.catalyst.plans.physical._
import org.apache.spark.sql.catalyst.util.truncatedString
-import org.apache.spark.sql.execution.CoalesceExec.EmptyPartition
import org.apache.spark.sql.execution.exchange._
import org.apache.spark.sql.execution.metric.SQLShuffleWriteMetricsReporter
import org.apache.spark.sql.metric.SQLColumnarShuffleReadMetricsReporter
@@ -186,16 +185,4 @@ object ColumnarShuffleExchangeExec extends Logging {
)
}
- class DummyPairRDDWithPartitions(@transient private val sc: SparkContext,
numPartitions: Int)
- extends RDD[Product2[Int, InternalRow]](sc, Nil) {
-
- override def getPartitions: Array[Partition] =
- Array.tabulate(numPartitions)(i => EmptyPartition(i))
-
- override def compute(
- split: Partition,
- context: TaskContext): Iterator[Product2[Int, InternalRow]] = {
- throw new UnsupportedOperationException
- }
- }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
