Thank you very much, that was really helpful
Cheers,
Federico
2017-11-08 13:51 GMT+01:00 Dawid Wysakowicz :
> Unforunately there is mistake in the docs the return type should be
> DataStream rather than SingleOuputStream
>
> The correct version should be:
>
> val patternStream: PatternStream[Eve
Unforunately there is mistake in the docs the return type should be DataStream
rather than SingleOuputStream
The correct version should be:
val patternStream: PatternStream[Event] = CEP.pattern(input, pattern)
val outputTag = OutputTag[String]("side-output")
val result: DataStream[ComplexEvent
Thank you very much, Dawid, for your thorough explanation, really useful. I
totally missed the distinction between timed-out events and complete
matches.
I'd like to ask you one more thing, about the flinkCEP scala api: in the
documentation, there is the following code:
val patternStream: Pattern
Hi Federico,
For your given input and pattern there should (and there are) only two
timeouted patterns:
5> Left(Map(start -> List(Event(100,2017-11-05T03:56:02
5> Left(Map(start -> List(Event(100,2017-11-05T06:00:02
It is because in your patterns say the next event after events with valu
Hey Frederico,
let me pull in Dawid (cc'd) who works on CEP. He can probably clarify
the expected behaviour here.
Best,
Ufuk
On Mon, Nov 6, 2017 at 12:06 PM, Federico D'Ambrosio
wrote:
> Hi everyone,
>
> I wanted to ask if FlinkCEP in the following scenario is working as it
> should, or I hav
Hi everyone,
I wanted to ask if FlinkCEP in the following scenario is working as it
should, or I have misunderstood its functioning.
I've got a keyedstream associated with the following pattern:
Pattern[Event].begin("start").where(_.value >=100).oneOrMore
.notNext("end").where(_.value >=100).wit
