柱铸造语法

Question

我已经在列的空间进入和离开该pyspark命令：

results2 = results.select(cast("`HCAHPS Base Score`" as int), `HCAHPS Base Score`, cast("HCAHPS Consistency Score" as int) `HCAHPS Consistency Score`) 

和我得到一个SyntaxError在第一的开始，因为INT（在前面的）。

Answer 1

在pyspark铸造就像做，

results2 = results.select(results['HCAHPS Base Score'].cast(IntergerType()),results['HCAHPS Consistency Score'].cast(IntegerType()))