添加字符串值的pyspark中的值

Question

我有如下字符串值。Spark版本是2.1

a=1\n2\n3\n4\n5

现在，当我给类型的上面的值，它处理如下

type(a)
<type 'str'>

现在我的逻辑需要按\n拆分并加上1,2,3,4,5的值我的输出必须是1,2,3,4,5 i，e 5的平均值

Answer 1

谢谢大家的支持

我已经解决了。下面是代码

val=os.popen("impala-shell -i  d1endevclo006.europe.easyjet.local -d default -k -q 'show table stats scheama.tbl'| cut -d'|' -f4|grep -Eo '[+-]*[0-9]+'|sed '$ d'").read().strip()
//Above output will return me in string
numbers = map(int, lst)
type(numbers)
return sum(numbers)/len(numbers)