Rui Wang created CALCITE-3509:
---------------------------------
Summary: Watermark Propagation
Key: CALCITE-3509
URL: https://issues.apache.org/jira/browse/CALCITE-3509
Project: Calcite
Issue Type: Sub-task
Reporter: Rui Wang
To have a useful enumerable implementation for streaming windowing semantic in
Calcite, and also make Emit syntax useful, we will need to introduce watermark
into Calcite. More specifically, the following should be discussed:
1. How is watermark generated? What changes are required on source/table scan?
2. How does watermark propagate through the whole plan?
3. Where watermark is used to control the time to emit data?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
