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 2f57eec (commit)
to 05699c3 (commit)
from 2f57eec Merge pull request #14817: [BEAM-8889] Upgrade GCSIO to 2.2.2
add ce3a554 don't hold watermark for expiry timer
add 1242cdc Merge pull request #15128: [BEAM-12579] Don't hold watermark
for expiry timer
add bff4be4 [BEAM-12596] Validate that @GetSize always returns a value
greater then zero.
add 72bead6 [BEAM-12596] Validate that @GetSize always returns a value
greater then zero.
add 4fd185d [BEAM-7372] restore docstring removed accidentally
add fc619bd Merge pull request #15158 from
lazylynx/fix/unintended_docstring_removal
add c440ed6 [BEAM-12531] Compat changes for deferred dataframes with
ib.show
add 79e4db9 address linter
add f82faed address linter
add e616db2 add license to dataframes.ipynb
add 2944e48 Merge pull request #15097 from rohdesamuel/int-df-show
add 598bbfc Cache readers after getting progress.
add 085667c [BEAM-12602] Put reader back into the cache after
getProgress()
add ccd3240 [BEAM-12515] Skip flaky PipelineOptions.test_display_data test
add aaab98a Merge pull request #15161 from apache/aaltay-patch-1
add 0b3100f [BEAM-12538] Allow PipelineOptions to be specified on command
line of ExpansionService (#15082)
add f0d718d Revert "[BEAM-12515] Revert "[BEAM-12119] [BEAM-12122] Add
integer and string `_id` keys support to Python IO MongoDB""
add 582e2af Merge pull request #15162 from
apache/revert-15115-revert-14460-BEAM-12122-Python-IO-MongoDB-integer-and-string-`_id`-keys-are-not-supported
add 05699c3 [BEAM-12590] Automatically upgrading Dataflow Python
pipelines that use cross-language transforms to Runner v2 (#15079)
No new revisions were added by this update.
Summary of changes:
.../src/main/java/org/apache/beam/sdk/io/Read.java | 56 ++-
.../apache/beam/sdk/transforms/Deduplicate.java | 7 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 2 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 40 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 81 ++++
.../sdk/expansion/service/ExpansionService.java | 80 +++-
.../sdk/expansion/service/ExpansionServerTest.java | 18 +
sdks/python/apache_beam/io/mongodbio.py | 491 +++++++++++++++------
sdks/python/apache_beam/io/mongodbio_test.py | 230 ++++++++--
sdks/python/apache_beam/io/range_trackers.py | 131 ++++--
sdks/python/apache_beam/io/range_trackers_test.py | 102 ++++-
.../apache_beam/options/pipeline_options_test.py | 1 +
.../runners/dataflow/dataflow_runner.py | 18 +-
.../interactive/display/pcoll_visualization.py | 20 +-
.../runners/interactive/interactive_beam.py | 42 +-
.../runners/interactive/interactive_beam_test.py | 22 +
.../runners/interactive/recording_manager.py | 7 +
.../Linux/29c9237ddf4f3d5988a503069b4d3c47.png | Bin 0 -> 64591 bytes
.../Linux/7a35f487b2a5f3a9b9852a8659eeb4bd.png | Bin 728121 -> 679724 bytes
.../integration/test_notebooks/dataframes.ipynb} | 58 +--
...it_square_cube_test.py => screen_diff_tests.py} | 17 +
sdks/python/apache_beam/transforms/core.py | 4 +
22 files changed, 1089 insertions(+), 338 deletions(-)
create mode 100644
sdks/python/apache_beam/runners/interactive/testing/integration/goldens/Linux/29c9237ddf4f3d5988a503069b4d3c47.png
copy sdks/python/apache_beam/runners/interactive/{examples/Interactive Beam
Running on Flink.ipynb => testing/integration/test_notebooks/dataframes.ipynb}
(58%)
rename
sdks/python/apache_beam/runners/interactive/testing/integration/tests/{init_square_cube_test.py
=> screen_diff_tests.py} (69%)
