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 vote209 views1 answer
How to remove last 2 rows in a dataframe
Python
0 vote194 views1 answer
Def extract_title(input_df):
Python
0 vote180 views1 answer
Search for a word in pdf using python
Python
2 votes188 views1 answer
Flask make static directory
Python Flask
0 vote175 views1 answer
Python list clear vs del
Python
2 votes204 views1 answer
Pyspark convert float results to integer replace
Python
0 vote200 views1 answer
Heroku how to access config vars django
Python Django
1 vote214 views1 answer
Django clear db
Python Django
68 votes188 views6 answers
Python open file
Python
0 vote141 views4 answers
Django forms I cannot save picture file
Python