[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu edited comment on FLINK-7293 at 7/31/17 7:00 AM:
---------------------------------------------------------
As the {{event-time}}/{{process-time}} has higher priority over custom {{order
by}}, so we can not first apply the custom sort and then pass it to the CEP
library.
{quote}
This is the same case as in DataStream, which does not have sort function.
{quote}
Actually there are some differences. For example, there is no sort logic in
DataStream at all, so all the sort logic can be implemented in Table API. While
there is already sort logic in CEP library (event time) which makes it
impossible to implement the sort in Table API without making the changes in
this JIRA. Thoughts?
was (Author: dian.fu):
As the {{event-time}}/{{process-time}} has higher priority over custom {{order
by}}, so we can not first apply the custom sort and then pass it to the CEP
library.
{quote}
This is the same case as in DataStream, which does not have sort function.
{quote}
Actually there are some differences. For example, there is no sort logic in
DataStream at all, so all the sort logic can be implemented in Table API. While
there is already sort logic in CEP library (event time) which makes us can not
implement the sort in Table API alone. Thoughts?
> Support custom order by in PatternStream
> ----------------------------------------
>
> Key: FLINK-7293
> URL: https://issues.apache.org/jira/browse/FLINK-7293
> Project: Flink
> Issue Type: Sub-task
> Components: CEP
> Reporter: Dian Fu
> Assignee: Dian Fu
>
> Currently, when {{ProcessingTime}} is configured, the events are fed to NFA
> in the order of the arriving time and when {{EventTime}} is configured, the
> events are fed to NFA in the order of the event time. It should also allow
> custom {{order by}} to allow users to define the order of the events besides
> the above factors.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
