Github user jkbradley commented on a diff in the pull request:
https://github.com/apache/spark/pull/19110#discussion_r138180599
--- Diff: python/pyspark/ml/param/shared.py ---
@@ -608,6 +608,30 @@ def getAggregationDepth(self):
return self.getOrDefault(self.aggregationDepth)
+class HasParallelism(Params):
+ """
+ Mixin for param parallelism: number of threads to use when fitting
models in parallel.
+ """
+
+ parallelism = Param(Params._dummy(), "parallelism", "the number of
threads to use when running parallel algorithms.",
typeConverter=TypeConverters.toInt)
--- End diff --
nit: Is this out of date? It's missing the "(>= 1)" from the code gen file.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
