Как преобразовать столбец Int в строку в Pyspark?

Question

Поскольку я новичок в Pyspark, может ли кто-нибудь помочь в преобразовании целочисленного столбца в строку?

Вот мой код в Aws Афина, и мне нужно преобразовать его в фрейм данных pyspark.

       case when A.[HHs Reach] = 0 or A.[HHs Reach] is null then '0'
        when A.[HHs Reach] = 1000000000 then '*'
        else cast(A.[HHs Reach] as varchar) end as [HHs Reach]

Answer 1

при условии, что df - ваш фрейм данных, примерно так:

from pyspark.sql import functions as F

df.withColumn(
    "HHs Reach",
    F.when(F.col("HHs Reach").isNull(), '0')
    .when(F.col("HHs Reach") == 1000000000, '*')
    .otherwise(F.col("HHs Reach").cast("string"))
)