[
https://issues.apache.org/jira/browse/BEAM-591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572540#comment-15572540
]
Raghu Angadi commented on BEAM-591:
---
PubSubIO does advance the watermark to current time
[
https://issues.apache.org/jira/browse/BEAM-591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438443#comment-15438443
]
Daniel Halperin commented on BEAM-591:
--
May be worth checking out PubSubIO. It has two