Luke Cwik created BEAM-1200:
-------------------------------
Summary: PubsubIO should allow for a user to supply the function
which computes the watermark that is reported
Key: BEAM-1200
URL: https://issues.apache.org/jira/browse/BEAM-1200
Project: Beam
Issue Type: Improvement
Components: sdk-java-gcp
Reporter: Luke Cwik
Assignee: Daniel Halperin
Priority: Minor
A user wanted to build a watermark function which tracked the datas watermark
but never falls behind current time more than Y minutes. PubsubIO does not
support specifying the function which computes and reports the watermark.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
