You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/08/18 21:13:00 UTC

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

Kostas Kloudas commented on FLINK-7479:
---------------------------------------

Hi [~dian.fu], 

Before opening a PR for a feature, we first have to discuss iff we want to include that feature in the library. 
If we do not go like this, then the only thing that will happen is that we pile up PRs that we do not know how to handle at the end. 

I have not looked at the code itself, but from the topic, this just seems to just be syntactic sugar on top of the existing APIs.
It may be necessary for completeness, as it is in the SQL specification, but a specification is just a specification until users start using it
or asking for it. Until users start using the library and ask for features, and given that this is a first iteration of the CEP/SQL integration, 
I would suggest to keep it to a minimal and avoid stuff that only contribute "facilitation methods" for already existing functionality.


> Support to retrieve the past event by physical offset 
> ------------------------------------------------------
>
>                 Key: FLINK-7479
>                 URL: https://issues.apache.org/jira/browse/FLINK-7479
>             Project: Flink
>          Issue Type: Sub-task
>          Components: CEP, Table API & SQL
>            Reporter: Dian Fu
>            Assignee: Dian Fu
>
> Currently, it's already able to retrieve events matched to the specifed pattern in {{IterativeCondition.Context}}. While there are also requirements to retrieve events by an physical offset. The retrieved events may not be matched to any pattern.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)