[SAMZA-1567] Allow user WatermarkFunction to exclude streams from Watermark computation

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 0.15.0
• Fix Version/s: 0.15.0
• Assignee: Xinyu Liu
• Reporter: Xinyu Liu
• Created: 24/Jan/18 22:34
• Updated: 26/Jan/18 21:06
• Resolved: 26/Jan/18 21:06

Description

Current watermark logic calculates the watermark based on the watermark from all the upstream operators. BEAM has a very special use case that requires excluding certain streams from this calcuation (view streams), and the watermark from these streams should be directly passed down to the WatermarkFunction.