[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873490#comment-16873490
]
Konstantin Knauf edited comment on FLINK-7129 at 6/26/19 4:24 PM:
------------------------------------------------------------------
[~Mostafa01] Generally speaking, you can implement a dynamic pattern matching
yourself with a {{KeyedBroadcastProcessFunction}}, where patterns are
broadcasted and the {{KeyedStream}} is checked against these patterns. The
complexity of this approach depends mostly on how complex/flexible the
patterns/rule are you would like to support.
was (Author: knaufk):
[~Mostafa01] Generally speaking, you can implement a dynamic pattern matching
yourself with a `KeyedBroadProcessFunction`, where patterns are broadcasted and
the `KeyedStream` is checked against these patterns. The complexity of this
approach depends mostly on how complex/flexible the patterns/rule are you would
like to support.
> Support dynamically changing CEP patterns
> -----------------------------------------
>
> Key: FLINK-7129
> URL: https://issues.apache.org/jira/browse/FLINK-7129
> Project: Flink
> Issue Type: New Feature
> Components: Library / CEP
> Reporter: Dawid Wysakowicz
> Priority: Major
>
> An umbrella task for introducing mechanism for injecting patterns through
> coStream
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
