Bucketizer pyspark

x = [(0,18.0),(1,19.0),(2,8.0),(3,5.0),(4,2.2),(5,4.0)]
d = spark.createDataFrame(x,["id","hour"])
d.show()
from pyspark.ml.feature import Bucketizer
splits = [0,1,2,3,4,float("Inf")]
buck = Bucketizer(splits=splits,inputCol="BATHSTOTAL",outputCol="baths")
df = buck.transform(df)
df[["BATHSTOTAL","baths"]].show()

Similar codes

13 votes245 views6 answers
Character in string python
Python
6 votes275 views2 answers
Flask get ip address of request
Python Flask
0 vote244 views1 answer
Shape
Python
0 vote303 views1 answer
REMOVE ALL ROWS FROM DATFRAME WGICH HAS DATA OLDER THAN 3 MONTHS PANDAS
Python
0 vote282 views1 answer
Python elasticsearch docker from within other container
Python
0 vote210 views0 answer
Python
0 vote327 views1 answer
: UserWarning: Matplotlib is currently using module://matplotlib_inline.backend_inline, which is a non-GUI backend,
Python
4 votes231 views1 answer
Matplotlib plot dashed
Python
0 vote237 views1 answer
Install pip3 for python 3.7
Python
2 votes260 views2 answers
Split datetime to date and time pandas
Python