You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by ch...@apache.org on 2025/10/28 09:58:04 UTC
(incubator-gluten) branch main updated: [MINOR][CORE] Remove unused class DummyPairRDDWithPartitions (#10931)
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 <Ch...@ibm.com>
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: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org