Чтобы округлить столбец до двух знаков после запятой в PySpark, вы можете использовать различные методы. Вот несколько подходов:
Метод 1: использование функции round
from pyspark.sql.functions import round
df = df.withColumn("rounded_column", round(df["your_column"], 2))
Метод 2. Использование функции format_number
from pyspark.sql.functions import format_number
df = df.withColumn("rounded_column", format_number(df["your_column"], 2))
Метод 3: использование метода pyspark.sql.Column.castс функциями DecimalTypeи toFixed
from pyspark.sql.types import DecimalType
from pyspark.sql.functions import col
df = df.withColumn("rounded_column", col("your_column").cast(DecimalType(10, 2)).toFixed(2))
Метод 4. Использование метода pyspark.sql.Column.castс функцией DoubleTypeи format_number
from pyspark.sql.types import DoubleType
from pyspark.sql.functions import col, format_number
df = df.withColumn("rounded_column", format_number(col("your_column").cast(DoubleType()), 2))