scala

Question

我正在编写一个简单的代码来在 Scala 中测试 CEP library，maven 依赖版本 1.1-SNAPSHOT。我的代码：

val res = igd.filter(_._2 == 13)
val pattern: Pattern[(Long,String,String,Long), _] = Pattern.begin[(Long,String,String,Long)]("start").where(_._3 == true).next("end").where(_._3 == false)
val patternStream: PatternStream[(Long,String,String,Long)] = CEP.pattern(res, pattern)

def selectFn(pattern : mutable.Map[String,(Long,String,String,Long)]): String = {
  val startEvent = pattern.get("start").get
  "Alerta:"+startEvent._1+": Pattern"
   }

val patternStreamSelected = patternStream.select(selectFn(_)).print

在 selecFn 中，地图显示为红色并带有消息 cannot resolve symbol Map 问题出在哪里？？先感谢您。

Answer 1

哦，我的...，我正在导入 scala.collection.parallel.mutable 而不是 scala.collection.mutable。无论如何，我认为 scala 库仍然不起作用，我的小测试没有做到，你可以阅读 Simple Scala API for CEP example don't show any output

scala - 无法解析符号映射

scala - cannot resolve symbol Map

flink-streaming

flink-cep