Skip to content

Commit d37c994

Browse files
author
Alexey Kudinkin
committed
(REBASE ME) Abstracting HoodieLogicalRelation in hudi-spark3-common
1 parent 36b961f commit d37c994

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ object HoodieAnalysis extends SparkAdapterSupport {
134134
}
135135
}
136136

137+
// TODO elaborate
137138
// TODO call out that can use Project in Spark 3.2+
138139
object ResolveHoodieLogicalRelations extends Rule[LogicalPlan] {
139140
private val hudiLogicalRelationTag: TreeNodeTag[Boolean] = TreeNodeTag("__hudi_logical_relation")
@@ -150,6 +151,7 @@ object ResolveHoodieLogicalRelations extends Rule[LogicalPlan] {
150151
}
151152
}
152153

154+
// TODO elaborate
153155
object FoldHoodieLogicalRelations extends Rule[LogicalPlan] {
154156
override def apply(plan: LogicalPlan): LogicalPlan =
155157
plan.transformDown {

hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/HoodieLogicalRelation.scala renamed to hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/HoodieLogicalRelation.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,9 @@ import org.apache.spark.sql.execution.datasources.LogicalRelation
2929
import scala.collection.JavaConverters._
3030

3131
// TODO elaborate
32-
case class HoodieLogicalRelation(override val child: LogicalRelation) extends UnaryNode with MultiInstanceRelation {
32+
case class HoodieLogicalRelation(override val child: LogicalRelation) extends UnaryNode
33+
with MultiInstanceRelation
34+
with HoodieUnaryLikeSham[LogicalPlan] {
3335

3436
val targetTable: CatalogTable = resolveHudiTable(child) match {
3537
case Some(table) => table

0 commit comments

Comments
 (0)