[BEAM-270] Support Timestamps/Windows in Flink Batch

• Type: Sub-task
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.1.0-incubating
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 09/May/16 11:41
• Updated: 24/Jul/20 20:54
• Resolved: 20/May/16 07:18

Description

Right now, Flink Batch execution does not use WindowedValue internally, this means that all programs that interact with timestamps/windows will not work. We should just internally wrap everything in WindowedValue as we do in Flink Streaming. This also makes it very straightforward to add support for windows.

Issue Links

• duplicates: BEAM-236 Implement Windowing in batch execution
• links to: GitHub Pull Request #328
• links to: GitHub Pull Request #335
• links to: GitHub Pull Request #343
• links to: GitHub Pull Request #398