Hello I have created a simple pattern with FlinkCEP 1.3 as well as a simple pattern select function. My simple function is as follows:
def myFunction(pattern: Map[String,Iterable[MyEventType]]): MyEventType = { val startEvent = pattern.get("first").get.head val endEvent = pattern.get("second").get.head // dummy functionality for illustrating purposes endEvent } When I apply the function above to a pattern in the following way: CEP.pattern(myKeyedStream,myDummyPattern).select(myFunction(_)) it gives the following error: Cannot resolve reference myFunction with such signature. Type mismatch, expected: scala.Predef.Map[scala.Predef.String,scala.Iterable[MyEventType]], actual: scala.collection.Map[scala.Predef.String,scala.Iterable[MyEventType]] What is the reason of this behavior? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/FlinkCEP-1-3-scala-cannot-apply-select-function-tp13824.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.