This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 02331f88f60af14f453da7c8fbf079e45324c07a Merge: d8cb0e6 fbbc6ab Author: Ahmet Altay <[email protected]> AuthorDate: Mon Mar 19 09:51:37 2018 -0700 Merge pull request #4838 from mariapython/side [BEAM-3818] Add support for streaming side inputs in the DirectRunner (part I: update _SideInputsContainer as the watermark advances) .../runners/direct/evaluation_context.py | 43 +++++++++--- .../runners/direct/watermark_manager.py | 14 ++-- .../python/apache_beam/testing/test_stream_test.py | 80 ++++++++++++++++++++++ 3 files changed, 124 insertions(+), 13 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
