Skip to content

Commit a2e24c0

Browse files
committed
add python example
1 parent d3831a7 commit a2e24c0

File tree

1 file changed

+46
-0
lines changed

1 file changed

+46
-0
lines changed
Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
#
2+
# Licensed to the Apache Software Foundation (ASF) under one or more
3+
# contributor license agreements. See the NOTICE file distributed with
4+
# this work for additional information regarding copyright ownership.
5+
# The ASF licenses this file to You under the Apache License, Version 2.0
6+
# (the "License"); you may not use this file except in compliance with
7+
# the License. You may obtain a copy of the License at
8+
#
9+
# http://www.apache.org/licenses/LICENSE-2.0
10+
#
11+
# Unless required by applicable law or agreed to in writing, software
12+
# distributed under the License is distributed on an "AS IS" BASIS,
13+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
# See the License for the specific language governing permissions and
15+
# limitations under the License.
16+
#
17+
18+
# $example on$
19+
from pyspark.ml.feature import Imputer
20+
# $example off$
21+
from pyspark.sql import SparkSession
22+
23+
if __name__ == "__main__":
24+
spark = SparkSession\
25+
.builder\
26+
.appName("imputer example")\
27+
.getOrCreate()
28+
29+
# $example on$
30+
dataFrame = spark.createDataFrame([
31+
(1.0, float("nan")),
32+
(2.0, float("nan")),
33+
(float("nan"), 3.0),
34+
(4.0, 4.0),
35+
(5.0, 5.0)
36+
], ["a", "b"])
37+
38+
imputer = Imputer(inputCols=["a", "b"], outputCols=["out_a", "out_b"])
39+
40+
imputerModel = imputer.fit(dataFrame)
41+
42+
imputedData = imputerModel.transform(dataFrame)
43+
imputedData.select("a", "b", "out_a", "out_b").show()
44+
# $example off$
45+
46+
spark.stop()

0 commit comments

Comments
 (0)