Re: Get access to unmatching events in Apache Flink Cep
In answer Biao said "currently there is no such API to access the middle
NFA state". May be that API exist in plan? Or I can create issue or pull
request that add API?
пт, 17 мая 2024 г. в 12:04, Anton Sidorov :
> Ok, thanks for the reply.
>
> пт, 17 мая 2024 г. в 09:22, Biao Geng :
>
>> Hi Anton,
>>
>> I am afraid that currently there is no such API to access the middle NFA
>> state in your case. For patterns that contain 'within()' condition, the
>> timeout events could be retrieved via TimedOutPartialMatchHandler
>> interface, but other unmatching events would be pruned immediately once
>> they are considered as unnecessary to keep.
>>
>> Best,
>> Biao Geng
>>
>>
>> Anton Sidorov 于2024年5月16日周四 16:12写道：
>>
>>> Hello!
>>>
>>> I have a Flink Job with CEP pattern.
>>>
>>> Pattern example:
>>>
>>> // Strict Contiguity
>>> // a b+ c d e
>>> Pattern.begin("a", AfterMatchSkipStrategy.skipPastLastEvent()).where(...)
>>> .next("b").where(...).oneOrMore()
>>> .next("c").where(...)
>>> .next("d").where(...)
>>> .next("e").where(...);
>>>
>>> I have events with wrong order stream on input:
>>>
>>> a b d c e
>>>
>>> On output I haven`t any matching. But I want have access to events, that
>>> not matching.
>>>
>>> Can I have access to middle NFA state in CEP pattern, or get some other
>>> way to view unmatching events?
>>>
>>> Example project with CEP pattern on github
>>> <https://github.com/A-Kinski/apache-flink-cep/tree/main>, and my question
>>> on SO
>>> <https://stackoverflow.com/questions/78483004/get-access-to-unmatching-events-in-apache-flink-cep>
>>>
>>> Thanks in advance
>>>
>>
>
> --
> С уважением, Антон.
>
--
С уважением, Антон.
Re: Get access to unmatching events in Apache Flink Cep
Ok, thanks for the reply.
пт, 17 мая 2024 г. в 09:22, Biao Geng :
> Hi Anton,
>
> I am afraid that currently there is no such API to access the middle NFA
> state in your case. For patterns that contain 'within()' condition, the
> timeout events could be retrieved via TimedOutPartialMatchHandler
> interface, but other unmatching events would be pruned immediately once
> they are considered as unnecessary to keep.
>
> Best,
> Biao Geng
>
>
> Anton Sidorov 于2024年5月16日周四 16:12写道：
>
>> Hello!
>>
>> I have a Flink Job with CEP pattern.
>>
>> Pattern example:
>>
>> // Strict Contiguity
>> // a b+ c d e
>> Pattern.begin("a", AfterMatchSkipStrategy.skipPastLastEvent()).where(...)
>> .next("b").where(...).oneOrMore()
>> .next("c").where(...)
>> .next("d").where(...)
>> .next("e").where(...);
>>
>> I have events with wrong order stream on input:
>>
>> a b d c e
>>
>> On output I haven`t any matching. But I want have access to events, that
>> not matching.
>>
>> Can I have access to middle NFA state in CEP pattern, or get some other
>> way to view unmatching events?
>>
>> Example project with CEP pattern on github
>> <https://github.com/A-Kinski/apache-flink-cep/tree/main>, and my question
>> on SO
>> <https://stackoverflow.com/questions/78483004/get-access-to-unmatching-events-in-apache-flink-cep>
>>
>> Thanks in advance
>>
>
--
С уважением, Антон.
RE: monitoring message latency for flink sql app
Hello mete. I found this SO article https://stackoverflow.com/questions/54293808/measuring-event-time-latency-with-flink-cep If I'm not mistake, you can use Flink metrics system for operators and get time of processing event in operator. On 2024/05/16 11:54:44 mete wrote: > Hello, > > For an sql application using kafka as source (and kafka as sink) what would > be the recommended way to monitor for processing delay? For example, i want > to be able to alert if the app has a certain delay compared to some event > time field in the message. > > Best, > Mete >
Get access to unmatching events in Apache Flink Cep
Hello!
I have a Flink Job with CEP pattern.
Pattern example:
// Strict Contiguity
// a b+ c d e
Pattern.begin("a", AfterMatchSkipStrategy.skipPastLastEvent()).where(...)
.next("b").where(...).oneOrMore()
.next("c").where(...)
.next("d").where(...)
.next("e").where(...);
I have events with wrong order stream on input:
a b d c e
On output I haven`t any matching. But I want have access to events, that
not matching.
Can I have access to middle NFA state in CEP pattern, or get some other way
to view unmatching events?
Example project with CEP pattern on github
, and my question
on SO
Thanks in advance
Get access to unmatching events in Apache Flink Cep
Hello!
I have a Flink Job with CEP pattern.
Pattern example:
// Strict Contiguity
// a b+ c d e
Pattern.begin("a", AfterMatchSkipStrategy.skipPastLastEvent()).where(...)
.next("b").where(...).oneOrMore()
.next("c").where(...)
.next("d").where(...)
.next("e").where(...);
I have events with wrong order stream on input:
a b d c e
On output I haven`t any matching. But I want have access to events, that
not matching.
Can I have access to middle NFA state in CEP pattern, or get some other way
to view unmatching events?
Example project with CEP pattern on github
, and my question
on SO
Thanks in advance
