Skip to content

Commit 3481649

Browse files
zhengruifengcloud-fan
authored andcommitted
[SPARK-7008][SDP][ML] Make org.apache.spark.sql.pipelines internal package and make EstimatorUtils private
### What changes were proposed in this pull request? Make org.apache.spark.sql.pipelines internal package and make EstimatorUtils private ### Why are the changes needed? they should not be exposed to end users ### Does this PR introduce _any_ user-facing change? no ### How was this patch tested? ci ### Was this patch authored or co-authored using generative AI tooling? no Closes #53444 from zhengruifeng/mk_EstimatorUtils_private. Authored-by: Ruifeng Zheng <[email protected]> Signed-off-by: Wenchen Fan <[email protected]>
1 parent 45a2604 commit 3481649

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

mllib/src/main/scala/org/apache/spark/ml/Estimator.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ abstract class Estimator[M <: Model[M]] extends PipelineStage {
106106
}
107107

108108

109-
object EstimatorUtils {
109+
private[spark] object EstimatorUtils {
110110
// This warningMessagesBuffer is for collecting warning messages during `estimator.fit`
111111
// execution in Spark Connect server.
112112
private[spark] val warningMessagesBuffer = new java.lang.ThreadLocal[ArrayBuffer[String]]() {

project/SparkBuild.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -367,6 +367,7 @@ object SparkBuild extends PomBuild {
367367
"org.apache.spark.kafka010",
368368
"org.apache.spark.network",
369369
"org.apache.spark.sql.avro",
370+
"org.apache.spark.sql.pipelines",
370371
"org.apache.spark.sql.scripting",
371372
"org.apache.spark.types.variant",
372373
"org.apache.spark.ui.flamegraph",
@@ -1531,6 +1532,7 @@ object Unidoc {
15311532
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/classic/")))
15321533
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/execution")))
15331534
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/internal")))
1535+
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/pipelines")))
15341536
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/scripting")))
15351537
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/ml")))
15361538
.map(_.filterNot(_.getCanonicalPath.contains("org/apache/spark/sql/hive")))

0 commit comments

Comments
 (0)