[ https://issues.apache.org/jira/browse/FLINK-5845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kostas Kloudas updated FLINK-5845: ---------------------------------- Issue Type: Sub-task (was: Bug) Parent: FLINK-5420 > CEP: unify key and non-keyed operators > -------------------------------------- > > Key: FLINK-5845 > URL: https://issues.apache.org/jira/browse/FLINK-5845 > Project: Flink > Issue Type: Sub-task > Components: CEP > Affects Versions: 1.3.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Fix For: 1.3.0 > > > Currently the keyed and non-keyed operators in the CEP library have different > implementations. This issue targets to unify them into one. > This new implementation will always be applied on a keyed stream, and in the > case of non-keyed usecases, the input stream will be keyed on a dummy keye, > as done in the case of the {{DataStream.windowAll()}} method, where the input > stream is keyed using the {{NullByteKeySelector}}. > This is a first step towards making the CEP operators rescalable. -- This message was sent by Atlassian JIRA (v6.3.15#6346)