M
Size: a a a
M
CO
M
CO
>>> df = spark.sql('select round(float(1539887), 2) as amount')
>>> df
DataFrame[amount: float]
>>> df.show()
+---------+
| amount|
+---------+
|1539887.0|
+---------+
>>> new_df = df.withColumn('amount', F.col('amount')*F.lit(100))
>>> new_df
DataFrame[amount: float]
>>> new_df.show()
+------------+
| amount|
+------------+
|1.53988704E8|
+------------+
>>> new_df2 = new_df.withColumn('amount', F.col('amount').cast(IntegerType()))
>>> new_df2
DataFrame[amount: int]
>>> new_df2.show()
+---------+
| amount|
+---------+
|153988704|
+---------+
>>> new_df3 = new_df2.withColumn('amount', F.col('amount')/F.lit(100))
>>> new_df3
DataFrame[amount: double]
>>> new_df3.show()
+----------+
| amount|
+----------+
|1539887.04|
+----------+CO
ЕГ
ЕГ
ЕГ
ЕГ
CO
ЕГ
ЕГ
C
C
CO
ЕГ
C
ЕГ
C
ЕГ