aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/pyspark/ml/pipeline.py2
-rw-r--r--python/pyspark/ml/tests.py4
-rw-r--r--python/pyspark/ml/tuning.py1
3 files changed, 4 insertions, 3 deletions
diff --git a/python/pyspark/ml/pipeline.py b/python/pyspark/ml/pipeline.py
index c1b2077c98..fdbae06405 100644
--- a/python/pyspark/ml/pipeline.py
+++ b/python/pyspark/ml/pipeline.py
@@ -179,7 +179,7 @@ class PipelineModel(Model):
return dataset
-class Evaluator(object):
+class Evaluator(Params):
"""
Base class for evaluators that compute metrics from predictions.
"""
diff --git a/python/pyspark/ml/tests.py b/python/pyspark/ml/tests.py
index 3a42bcf723..75bb5d749c 100644
--- a/python/pyspark/ml/tests.py
+++ b/python/pyspark/ml/tests.py
@@ -34,7 +34,7 @@ from pyspark.tests import ReusedPySparkTestCase as PySparkTestCase
from pyspark.sql import DataFrame
from pyspark.ml.param import Param
from pyspark.ml.param.shared import HasMaxIter, HasInputCol
-from pyspark.ml.pipeline import Transformer, Estimator, Pipeline
+from pyspark.ml.pipeline import Estimator, Model, Pipeline, Transformer
class MockDataset(DataFrame):
@@ -77,7 +77,7 @@ class MockEstimator(Estimator):
return model
-class MockModel(MockTransformer, Transformer):
+class MockModel(MockTransformer, Model):
def __init__(self):
super(MockModel, self).__init__()
diff --git a/python/pyspark/ml/tuning.py b/python/pyspark/ml/tuning.py
index 28e3727f2c..86f4dc7368 100644
--- a/python/pyspark/ml/tuning.py
+++ b/python/pyspark/ml/tuning.py
@@ -236,6 +236,7 @@ class CrossValidatorModel(Model):
"""
def __init__(self, bestModel):
+ super(CrossValidatorModel, self).__init__()
#: best model from cross validation
self.bestModel = bestModel