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

Posted to commits@beam.apache.org by mx...@apache.org on 2019/09/05 09:57:51 UTC

[beam] branch master updated (ce4cd3b -> 9983115)

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from ce4cd3b  Merge pull request #9464: [hotfix] Encode keys as NESTED for flink keyselector
     add 79d4bf2  Track PCollection boundedness in python sdk
     add 2e39266  Add tests
     add 9983115  Merge pull request #9426: [BEAM-8088] Track PCollection boundedness in Python SDK

No new revisions were added by this update.

Summary of changes:
 .../io/flink/flink_streaming_impulse_source.py     |  2 +-
 sdks/python/apache_beam/io/iobase.py               |  3 +-
 sdks/python/apache_beam/pipeline_test.py           | 60 ++++++++++++++++++++++
 sdks/python/apache_beam/pvalue.py                  | 19 +++++--
 .../runners/dataflow/dataflow_runner.py            | 11 ++--
 .../runners/dataflow/native_io/streaming_create.py |  2 +-
 .../apache_beam/runners/direct/direct_runner.py    |  2 +-
 .../runners/direct/sdf_direct_runner.py            |  2 +-
 sdks/python/apache_beam/runners/sdf_common.py      |  2 +-
 sdks/python/apache_beam/testing/test_stream.py     |  2 +-
 sdks/python/apache_beam/transforms/core.py         |  9 ++--
 11 files changed, 95 insertions(+), 19 deletions(-)