[
https://issues.apache.org/jira/browse/BEAM-3767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268216#comment-17268216
]
Ismaël Mejía commented on BEAM-3767:
------------------------------------
Hi [~devchouhan] sadly I don't have the availability to follow on this issue
now. I have the impression someone started working on this already for Beam's
SQL (BEAM-9543) so this is probably partially covered now.
> A Complex Event Processing (CEP) library/extension for Apache Beam
> ------------------------------------------------------------------
>
> Key: BEAM-3767
> URL: https://issues.apache.org/jira/browse/BEAM-3767
> Project: Beam
> Issue Type: New Feature
> Components: sdk-ideas
> Reporter: Ismaël Mejía
> Priority: P3
>
> Apache Beam [1] is a unified and portable programming model for data
> processing jobs. The Beam model [2, 3, 4] has rich mechanisms to process
> endless streams of events.
> Complex Event Processing [5] lets you match patterns of events in streams to
> detect important patterns in data and react to them.
> Some examples of uses of CEP are fraud detection for example by detecting
> unusual behavior (patterns of activity), e.g. network intrusion, suspicious
> banking transactions, etc. Also trend detection is another interesting use
> case in the context of sensors and IoT.
> The goal of this issue is to implement an efficient pattern matching library
> inspired by [6] and existing libraries like Apache Flink CEP [7] using the
> Apache Beam Java SDK and the Beam style guides [8]. Because of the time
> constraints of GSoC we will probably try to cover first simple patterns of
> the ‘a followed by b followed by c’ kind, and then if there is still time try
> to cover more advanced ones e.g. optional, atLeastOne, oneOrMore, etc.
> [1] [https://beam.apache.org/]
> [2] [https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-101]
> [3] [https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-102]
> [4]
> [https://static.googleusercontent.com/media/research.google.com/en//pubs/archive/43864.pdf]
> [5] [https://en.wikipedia.org/wiki/Complex_event_processing]
> [6] [https://people.cs.umass.edu/~yanlei/publications/sase-sigmod08.pdf]
> [7]
> [https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/cep.html]
> [8] [https://beam.apache.org/contribute/ptransform-style-guide/]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
