Skip to content

Commit

Permalink
Disable hack native write code
Browse files Browse the repository at this point in the history
  • Loading branch information
JkSelf committed Nov 21, 2023
1 parent b22c862 commit 0eb3c27
Show file tree
Hide file tree
Showing 6 changed files with 1 addition and 2,167 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,6 @@ import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
import org.apache.spark.sql.catalyst.plans.physical.{BroadcastMode, Partitioning}
import org.apache.spark.sql.catalyst.rules.Rule
import org.apache.spark.sql.execution.{ColumnarBuildSideRelation, SparkPlan}
import org.apache.spark.sql.execution.datasources.GlutenWriterColumnarRules.NativeWritePostRule
import org.apache.spark.sql.execution.exchange.BroadcastExchangeExec
import org.apache.spark.sql.execution.joins.BuildSideRelation
import org.apache.spark.sql.execution.metric.SQLMetric
Expand Down Expand Up @@ -463,7 +462,7 @@ class SparkPlanExecApiImpl extends SparkPlanExecApi {
* @return
*/
override def genExtendedColumnarPostRules(): List[SparkSession => Rule[SparkPlan]] = {
List(spark => NativeWritePostRule(spark))
List()
}

/**
Expand Down

This file was deleted.

Loading

0 comments on commit 0eb3c27

Please sign in to comment.