aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/python/ml/polynomial_expansion_example.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/src/main/python/ml/polynomial_expansion_example.py')
-rw-r--r--examples/src/main/python/ml/polynomial_expansion_example.py12
1 files changed, 7 insertions, 5 deletions
diff --git a/examples/src/main/python/ml/polynomial_expansion_example.py b/examples/src/main/python/ml/polynomial_expansion_example.py
index b46c1ba2f4..b464ee86b6 100644
--- a/examples/src/main/python/ml/polynomial_expansion_example.py
+++ b/examples/src/main/python/ml/polynomial_expansion_example.py
@@ -30,13 +30,15 @@ if __name__ == "__main__":
.getOrCreate()
# $example on$
- df = spark\
- .createDataFrame([(Vectors.dense([-2.0, 2.3]),),
- (Vectors.dense([0.0, 0.0]),),
- (Vectors.dense([0.6, -1.1]),)],
- ["features"])
+ df = spark.createDataFrame([
+ (Vectors.dense([-2.0, 2.3]),),
+ (Vectors.dense([0.0, 0.0]),),
+ (Vectors.dense([0.6, -1.1]),)
+ ], ["features"])
+
px = PolynomialExpansion(degree=3, inputCol="features", outputCol="polyFeatures")
polyDF = px.transform(df)
+
for expanded in polyDF.select("polyFeatures").take(3):
print(expanded)
# $example off$