scala - 来自值列表的循环数，在 Spark 和 Scala 中是正数和负数的混合

Question

有一个包含值列表的 RDD，这些值是正值和负值的混合。需要根据此数据计算周期数。

例如，

val range = List(sampleRange(2020,2030,2040,2050,-1000,-1010,-1020,起点,-1030,2040,-1020,2050,2040,2020,终点, -1060,-1030,-1010)

上面列表中每个值之间的间隔是 1 秒。即，2020 和 2030 以 1 秒为间隔记录，依此类推。

它从负转正并保持正 >= 2 秒的次数。
如果 >= 2 秒，则为一个循环。

周期数:逻辑
示例 1: 列表(1,2,3,4,5,6,-15,-66)
循环次数为1。
原因:当我们从列表的第一个元素移动到第 6 个元素时，我们有 5 个间隔，这意味着 5 秒。所以一个循环。当我们移动到列表的第 6 个元素时，它是一个负值。所以我们从第 6 个元素开始计数并移动到第 7 个元素。负数只有2个，间隔只有1个，所以不算循环。
示例 2:
列表(11,22,33,-25,-36,-43,20,25,28)
循环次数为3。
原因:当我们从列表的第一个元素移动到第三个元素时，我们有 2 个间隔，这意味着 2 秒。所以一个循环 当我们移动到列表的第 4 个元素时，它是一个负值。所以我们从第 4 个元素开始计数，然后移动到第 5、6 个元素。我们有 2 个间隔，这意味着 2 秒。所以一个循环 当我们移动到列表的第 7 个元素时，它是一个正值。所以我们从第 7 个元素开始计数，然后移动到第 8、9 个元素。我们有 2 个间隔，这意味着 2 秒。所以一个循环。

range 是用例中的 RDD。看起来像
scala> 范围
范围:Seq[com.Range] = List(XtreamRange(858,890,899,920,StartEngage,-758,-790,-890,-720,920,940,950))

Answer 1

您可以对此进行编码“有多少次它从负数变为正数并保持正数 >= 2 秒。如果 >= 2 秒则为一个循环。”几乎直接进入与守卫的模式匹配。表达式 if(h < 0 && ht > 0 && hht > 0)检查循环并将结果加一，然后继续列表的其余部分。

def countCycles(xs: List[Int]): Int = xs match {
 case Nil => 0
 case h::ht::hht::t if(h < 0 && ht > 0 && hht > 0) => 1 + countCycles(t)
 case h::t => countCycles(t)
}

scala> countCycles(range)
res7: Int = 1