Объединение DataStream и PatternStream - PullRequest
Новая
       51

Объединение DataStream и PatternStream

0 голосов
/ 08 октября 2019 
val a  = keyedPatStream.map(_._1)//String
   val b = keyedStream.map(_._1)//String

val c = keyedPatStream.map(_._2)//Double
   val d = keyedStream.map(_._2)//Double

   val pat = Pattern.begin[(String, Double),(String, Double)]("start")
       .where((a == b) && (c >= d))

Ошибка: -

перегруженное значение метода начинается с альтернативы: (pattern: org.apache.flink.cep.scala.pattern.Pattern [(String, Double), (String), Double)], afterMatchSkipStrategy: org.apache.flink.cep.nfa.aftermatch.AfterMatchSkipStrategy) org.apache.flink.cep.scala.pattern.GroupPattern [(String, Double), (String, Double)] (шаблон:org.apache.flink.cep.scala.pattern.Pattern [(String, Double), (String, Double)]) org.apache.flink.cep.scala.pattern.GroupPattern [(String, Double), (String,Double)] нельзя применить к (String)

...