我正在使用saveAsTextFile(path)以便将输出保存为文本文件,以便将结果导入DB.输出看起来像这样:
(value1, value2)
如何删除括号？
我在密钥,值结构中有RDD(someKey,(measure1,measure2)).我按键分组,现在我想聚合每个键的值.
val RDD1 : RDD[(String,(Int,Int))]
RDD1.groupByKey()
我需要的结果是:
key: avg(measure1), avg(measure2), max(measure1), max(measure2), min(measure1), min(measure2), count(*)