Aljoscha Krettek created BEAM-270: ------------------------------------- Summary: Use WindowedValue in Flink Batch Key: BEAM-270 URL: https://issues.apache.org/jira/browse/BEAM-270 Project: Beam Issue Type: Improvement Components: runner-flink Reporter: Aljoscha Krettek
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 message was sent by Atlassian JIRA (v6.3.4#6332)