[FLINK-6165] Implement internal continuity for looping states.

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Component/s: Library / CEP
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 22/Mar/17 13:28
• Updated: 30/Mar/17 11:30
• Resolved: 30/Mar/17 11:30

Description

We should be able to specify an internal continuity for a looping state. The API could look like: zeroOrMore().consecutive(). So that we have a continuity up to the first element of a loop and between elements in the loop.

Issue Links

• links to: GitHub Pull Request #3621