You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Charles Chen (JIRA)" <ji...@apache.org> on 2017/11/07 20:18:00 UTC

[jira] [Created] (BEAM-3153) Allow streaming processing time domain timers in Beam Python DirectRunner

Charles Chen created BEAM-3153:
----------------------------------

             Summary: Allow streaming processing time domain timers in Beam Python DirectRunner
                 Key: BEAM-3153
                 URL: https://issues.apache.org/jira/browse/BEAM-3153
             Project: Beam
          Issue Type: Bug
          Components: sdk-py-core
            Reporter: Charles Chen
            Assignee: María GH


Currently, streaming execution in the Python Beam DirectRunner only allows for watermark domain timers and does not allow for processing time timers.  We should support processing time timers, along with a testing framework (potentially with a fake clock) that lets us test this behavior using the TestStream primitive.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)