【发布时间】:2020-03-25 22:53:05
【问题描述】:
我正在尝试生成包含元组数组的 RDD,该数组将国家名称作为第一个元素,将元组的最小整数作为第二个元素。
我这里有这段代码。
val test = sc.parallelize(Array(("US", (4,2)), ("France", (1,2)), ("Italy", (2,3))))
我想将一个变量存储为如下所示的值:
Array( ("US", 2), ("France", 1), ("Italy", 2) )
我尝试使用此代码,但它产生了“Value min is not a member of (Int, Int)”错误。
val test1 = test.map(x => (x._1, x._2.min))
如何获得Tuple2[Int, Int]的最小值?
【问题讨论】: