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

0 vote161 views4 answers
Write in multiple files python
Python
2 votes129 views1 answer
Torch device
Python
0 vote144 views1 answer
How to use python-socker.io with fast api
Python
0 vote170 views1 answer
Parser.add_argument array python
Python
0 vote222 views1 answer
Free the Bunny Prisoners
Python
3 votes128 views2 answers
How to install pygame in python 3.8
Python
0 vote125 views1 answer
Streaming upload requests python
Python
4 votes135 views2 answers
Python read entire file
Python
0 vote123 views2 answers
Python declare 2d array size
Python
0 vote126 views1 answer
How ti maek a prinyt comnad i pyuthon
Python