flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition
Date Tue, 02 Aug 2016 10:22:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15403722#comment-15403722
] 

Till Rohrmann commented on FLINK-3414:
--------------------------------------

Hi [~ivan.mushketyk],

I think it would be a good idea to first create a draft of the DSL before investigating too
much effort into the implementation. That way the community can discuss whether the DSL makes
sense and is useful without risking that you have to make too big changes later on.

> Add Scala API for CEP's pattern definition
> ------------------------------------------
>
>                 Key: FLINK-3414
>                 URL: https://issues.apache.org/jira/browse/FLINK-3414
>             Project: Flink
>          Issue Type: Improvement
>          Components: CEP
>    Affects Versions: 1.0.0
>            Reporter: Till Rohrmann
>            Assignee: Ivan Mushketyk
>            Priority: Minor
>
> Currently, the CEP library only supports a Java API to specify complex event patterns.
In order to make it a bit less verbose for Scala users, it would be nice to also add a Scala
API for the CEP library. 
> A Scala API would also allow to pass Scala's anonymous functions as filter conditions
or as a select function, for example, or to use partial functions to distinguish between different
events.
> Furthermore, the Scala API could be designed to feel a bit more like a DSL:
> {code}
> begin "start" where _.id >= 42 -> "middle_1" as classOf[Subclass] || "middle_2"
where _.name equals "foobar" -> "end" where x => x.id <= x.volume
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message