You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/06/09 02:56:42 UTC
[beam] tag nightly-master updated (4e22ff3 -> f07d2a2)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 4e22ff3 (commit)
to f07d2a2 (commit)
from 4e22ff3 [BEAM-9547] More WontImplement operations (#14910)
add 1b83efb [BEAM-12074] Add special explanation for head/tail pointing to interactive Beam and nlargest (#14961)
add e4c99da [BEAM-11811] Disallow num_workers > max_num_workers for Go Dataflow runner
add 2035e1b Merge pull request #14955 from zhoufek/wsc_go
add 21f25eb [BEAM-11811] Disallow num_workers > max_num_workers for Python DataflowRunner (#14938)
add d238c27 Minor: Remove pandas 0.x information in dataframe schema notes (#14965)
add 5448b64 [BEAM-12074] Define docstrings for all DataFrame operations (#14876)
add c680c65 [BEAM-11205] Added libraries-bom version to CHANGES.md
add 41ba9b2 Merge pull request #14925 from suztomo/libraries-bom_release_note
add dcd08a1 [BEAM-12439] Reuse Java job servers in spark_runner.py.
add f07d2a2 Merge pull request #14941 from ibzib/BEAM-12439
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 13 +
.../beam/runners/dataflow/dataflowlib/job_test.go | 33 +++
sdks/python/apache_beam/dataframe/frame_base.py | 24 +-
sdks/python/apache_beam/dataframe/frames.py | 279 ++++++++++++++-------
sdks/python/apache_beam/dataframe/frames_test.py | 22 +-
.../apache_beam/dataframe/pandas_doctests_test.py | 22 +-
sdks/python/apache_beam/dataframe/schemas.py | 15 +-
.../python/apache_beam/options/pipeline_options.py | 3 +-
.../options/pipeline_options_validator.py | 18 ++
.../options/pipeline_options_validator_test.py | 58 +++++
.../portability/spark_java_job_server_test.py | 65 +++++
.../runners/portability/spark_runner.py | 14 +-
13 files changed, 447 insertions(+), 121 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/portability/spark_java_job_server_test.py