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

12 votes288 views2 answers
Get python version jupyter
Python
2 votes367 views4 answers
Show pandas all data
Python
0 vote279 views3 answers
In is_lodes_form( : Missing id-axis pairings.
Python
21 votes282 views2 answers
Convert column to datetime format python
Python
0 vote282 views2 answers
Dropna threshold
Python
-1 vote374 views1 answer
How to delete django superuser
Python Django
10 votes276 views3 answers
Python list of dict to dataframe
Python
0 vote277 views1 answer
Python create sqlite db in memory
Python
0 vote343 views1 answer
Merge two Querysets in Python Django while preserving Queryset methods
Python Django
0 vote283 views1 answer
Scrape email in a list from website python
Python