python - 获取 int() 参数必须是字符串或数字，而不是 'Column' - Apache Spark

Question

如果我使用以下代码，我会收到此异常:

int() argument must be a string or a number, not 'Column'

df= df.withColumn('FY',
    F.when((df['ID'].substr(5,2).isin({'11','12'})),int(df['ID'].substr(1,4))+1).
    otherwise(int(df['ID'].substr(1,4))))

基本上，如果结果在 11 或 12 中，我想在结果中加 1，否则只需使用 ID。请帮忙，我是 Python 的新手。

Answer 1

使用:

df.withColumn('FY',F.when(df['ID'].substr(5,2).isin({'11','12'}),
  df['ID'].substr(1,4).cast("integer") + 1).
  otherwise(df['ID'].substr(1,4)).cast("integer"))