添加字符串值的pyspark中存在的值答案

【问题标题】：Adding values present in pyspark of string value添加字符串值的pyspark中存在的值
【发布时间】：2018-07-30 09:26:07
【问题描述】：

我的字符串值如下。 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 的平均值

【问题讨论】：

请澄清您的具体问题或添加其他详细信息以准确突出您的需要。正如目前所写的那样，很难准确地说出你在问什么。请参阅How to Ask 页面以获得澄清此问题的帮助。
我的输入是 pyspark 中的字符串值 a=1\n2\n3\n4\n5。我必须用 \n 解析它并添加这 5 个值的平均值
1,2,3,4,5的平均值是3
我的坏 Soheil 是的，同意。不总和它是平均的
您从哪里读取数据？来自文件？

标签： python

【解决方案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)

【讨论】：