[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449216#comment-15449216
]
Hao Chen commented on FLINK-4520:
---------------------------------
If there is no more problem, I would like to volunteer to work on this feature.
> Integrate Siddhi as a lightweight CEP Library
> ---------------------------------------------
>
> Key: FLINK-4520
> URL: https://issues.apache.org/jira/browse/FLINK-4520
> Project: Flink
> Issue Type: New Feature
> Components: CEP
> Affects Versions: 1.2.0
> Reporter: Hao Chen
> Labels: cep, library
>
> h1. Flink Siddhi CEP Integration Proposal
> h2. About Siddhi CEP
> Siddhi CEP is a lightweight, easy-to-use Open Source Complex Event Processing
> Engine (CEP) released as a Java Library under Apache Software License v2.0.
> Siddhi CEP processes events which are generated by various event sources,
> analyses them and notifies appropriate complex events according to the user
> specified queries.
> * http://wso2.com/products/complex-event-processor/
> * https://github.com/wso2/siddhi
> h2. Proposal
> As known, siddhi is very lightweight and rich featured CEP library,
> supporting most traditional CEP cases like:
> * Filter
> * Join
> * Aggregation
> * Group by
> * Having
> * Window
> * Conditions and Expressions
> * Pattern processing
> * Sequence processing
> * Event Tables
> * Partitions
> * Scripting:Support JavaScript & Scala Scripts within Siddhi Queries
> * Query: SQL like query language
> The proposal is to
> * Embed siddhi CEP as an stream operator of Flink
> * Support native siddhi query, extensions to run inside Flink
> StreamExecutionEnvironment
> * Integrate state management.
> * Provide consistent DSL to integrate with Flink programing API.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
