[FLINK-1657] Make count windows local automatically

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 0.9
• Component/s: API / DataStream
• Assignee: Gyula Fora
• Reporter: Gyula Fora
• Created: 06/Mar/15 11:44
• Updated: 28/Feb/19 11:15
• Resolved: 15/Mar/15 17:03

Description

Count windows should be automatically discretized in parallel as it doesnt break the assumptions on the window:

ds.window(Count.of(10)) is equivalent to ds.window(Count.of(10)).local() if we dont make ordering guarantees and the second version is distributed.