Pablo Estrada created BEAM-7799:
-----------------------------------

             Summary: Support Splittable DoFn in Flink Streaming Runner
                 Key: BEAM-7799
                 URL: https://issues.apache.org/jira/browse/BEAM-7799
             Project: Beam
          Issue Type: Improvement
          Components: runner-flink
            Reporter: Pablo Estrada


The portable Flink runner should be able to execute SDFs in Python Streaming, 
and keep track of things like the watermarks for event time, and synchronized 
processing time.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to