[FLINK-5845] CEP: unify key and non-keyed operators

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.0
• Component/s: Library / CEP
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 20/Feb/17 08:49
• Updated: 24/Feb/17 10:24
• Resolved: 24/Feb/17 10:24

Description

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 key, 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.

Issue Links

• links to: GitHub Pull Request #3375