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

3 votes231 views1 answer
Business logic in django
Python Django
0 vote180 views1 answer
Df filter out rows that appear more than x times
Python
7 votes182 views2 answers
Apply lambda with if
Python
-1 vote175 views2 answers
Sequence in python
Python
0 vote177 views1 answer
Date component
Python
10 votes171 views2 answers
How to find length of number in python
Python
0 vote171 views2 answers
Print(), .lower() and .upper() are all different _____________ you can use in python.
Python
2 votes146 views1 answer
Os.getlogin() python
Python
0 vote179 views1 answer
Sum with conditional python
Python
1 vote195 views1 answer
From datetime to unix timestamp
Python