This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 8d1580e63fc [MINOR] Unify updatePrunedDataSchema method return type
(#9629)
8d1580e63fc is described below
commit 8d1580e63fc66f6834d38729bb1f811ef4582013
Author: huangxiaoping <[email protected]>
AuthorDate: Tue Sep 12 16:57:27 2023 +0800
[MINOR] Unify updatePrunedDataSchema method return type (#9629)
---
.../src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala | 2 +-
.../src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala | 2 +-
.../src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala | 2 +-
.../org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala | 1 -
4 files changed, 3 insertions(+), 4 deletions(-)
diff --git
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala
index 7c0e2acfec0..94f8cbfc433 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala
@@ -106,6 +106,6 @@ case class HoodieBootstrapMORRelation(override val
sqlContext: SQLContext,
}
- override def updatePrunedDataSchema(prunedSchema: StructType):
HoodieBootstrapMORRelation =
+ override def updatePrunedDataSchema(prunedSchema: StructType): Relation =
this.copy(prunedDataSchema = Some(prunedSchema))
}
diff --git
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala
index 269401e5695..5339368ed55 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala
@@ -55,7 +55,7 @@ case class HoodieBootstrapRelation(override val sqlContext:
SQLContext,
HoodieBootstrapSplit(dataFile, skeletonFile)
}
- override def updatePrunedDataSchema(prunedSchema: StructType):
HoodieBootstrapRelation =
+ override def updatePrunedDataSchema(prunedSchema: StructType): Relation =
this.copy(prunedDataSchema = Some(prunedSchema))
def toHadoopFsRelation: HadoopFsRelation = {
diff --git
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala
index 8e35a9a8665..31d64d50e45 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala
@@ -49,7 +49,7 @@ case class MergeOnReadSnapshotRelation(override val
sqlContext: SQLContext,
override type Relation = MergeOnReadSnapshotRelation
- override def updatePrunedDataSchema(prunedSchema: StructType):
MergeOnReadSnapshotRelation =
+ override def updatePrunedDataSchema(prunedSchema: StructType): Relation =
this.copy(prunedDataSchema = Some(prunedSchema))
override protected def shouldIncludeLogFiles(): Boolean = {
diff --git
a/hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala
b/hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala
index 271701032ff..fcc2aa30c3b 100644
---
a/hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala
+++
b/hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala
@@ -68,4 +68,3 @@ class Spark32ResolveHudiAlterTableCommand(sparkSession:
SparkSession) extends Ru
}
}
}
-
