Spark RDD double compare error: value > is not a member of (Double, Double)

Question

我想在 pairthree 中，(a,(b,c)) 只过滤 c>100

pairthree.take(3)

res8: Array[(Double, (Double, Double))] = Array((44966.0,(6.5,2.0)), (5015.0,(879.0,248.0)), (47202.0,(32.0,8.0) ))

val pairhundred =pairthree.filter { case(k, v) => v > 100.0 }.take(3)

command-173749889538375:2: 错误：值 > 不是 (Double, Double) 的成员 val pairhundred =pairthree.filter { case(k, v) => v > 100.0 }.take(3)

我不明白为什么会出现这个错误...

Answer 1

v 是 Tuple 类型。试试下面的代码。

检查元组first参数> 100

val pairhundred =pairthree.filter { case(k, v) => v._1 > 100.0 }.take(3)

检查元组second参数> 100

val pairhundred =pairthree.filter { case(k, v) => v._2 > 100.0 }.take(3)

检查元组both参数> 100

val pairhundred =pairthree.filter { case(k, v) => (v._1 > 100.0 || v._2 > 100.0) }.take(3)

scala