You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2019/06/03 20:49:57 UTC
[beam] 01/01: [BEAM-7443] Create a BoundedSource -> SDF wrapper in
Python SDK
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 37326d3988af4a78008e6d44d9647c190aaffe2e
Merge: a189e31 8bbdc8c
Author: Lukasz Cwik <lu...@gmail.com>
AuthorDate: Mon Jun 3 13:49:43 2019 -0700
[BEAM-7443] Create a BoundedSource -> SDF wrapper in Python SDK
sdks/python/apache_beam/io/concat_source_test.py | 4 +-
sdks/python/apache_beam/io/iobase.py | 233 ++++++++++++++++++++-
sdks/python/apache_beam/io/iobase_test.py | 150 +++++++++++++
sdks/python/apache_beam/io/restriction_trackers.py | 5 +-
.../runners/dataflow/dataflow_runner.py | 7 +
.../runners/dataflow/internal/apiclient.py | 7 +
.../runners/dataflow/ptransform_overrides.py | 17 ++
.../runners/portability/fn_api_runner.py | 12 ++
.../runners/portability/fn_api_runner_test.py | 32 ++-
9 files changed, 456 insertions(+), 11 deletions(-)