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 2bb60c3 (commit)
to 5705526 (commit)
from 2bb60c3 Merge pull request #12789 from edre/patch-1
add b16742b [BEAM-10791] Identify and log additional information needed
to debug streaming insert requests for Python SDK
add 2cf1737 share histogram in a single process
add 33c9e34 add tests
add cfe61fd add comments
add e521d10 safer locking
add f08762f addressing comments
add ccd5d6b fix tests
add 3613ac5 get atomic percentile loggings
add 50009a8 add tests
add 4635afb Merge pull request #12754 from ihji/BEAM-10791
add 70092d6 [BEAM-10864] Update Snowflake JDBC dependency (#12793)
add 6b18b59 Merge pull request #12709 from [BEAM-8258] add more options
and monitoring to nexmark launcher
add b011a22 [BEAM-10860] avoid dictionary size change when shutting down
BundleProcessorCache
add 1377299 Merge pull request #12783 from
lazylynx/avoid_dictionary_size_change_when_BundleProcessorCache_shutdown
add a3d947c Fix Python formatting on master branch
add 6213d47 Merge pull request #12795 from kamilwu/fix-formatting
add b6d0abb [BEAM-10863] Change encoding of Pubsub sink to global window.
add 8bae9b3 Merge pull request #12791 from [BEAM-10863] Change encoding
of Pubsub sink to global window.
add 40275ab [BEAM-7925]add projection
add 25a2368 [BEAM-7925]spotless
add a334bac [BEAM-7925]add schema encoder
add 2dc5048 rename and remove duplicates
add 4911453 Modify description
add 1c3a9c2 Add description
add 5705526 Merge pull request #12786 from danielxjd/addprojection
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../beam/runners/dataflow/DataflowRunner.java | 7 +-
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 86 ++++++-
.../apache/beam/sdk/io/parquet/ParquetIOTest.java | 57 ++++-
sdks/java/io/snowflake/build.gradle | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 39 ++-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 1 +
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 26 +-
.../apache_beam/io/gcp/bigquery_tools_test.py | 20 ++
.../python/apache_beam/options/pipeline_options.py | 21 ++
.../runners/dataflow/internal/apiclient.py | 7 +-
.../apache_beam/runners/worker/sdk_worker.py | 5 +-
.../testing/benchmarks/nexmark/nexmark_launcher.py | 281 ++++++++++++++-------
.../testing/benchmarks/nexmark/nexmark_perf.py | 54 ++++
.../testing/benchmarks/nexmark/nexmark_util.py | 46 +++-
sdks/python/apache_beam/utils/histogram.py | 207 +++++++++++++++
sdks/python/apache_beam/utils/histogram_test.py | 134 ++++++++++
17 files changed, 867 insertions(+), 127 deletions(-)
create mode 100644
sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_perf.py
create mode 100644 sdks/python/apache_beam/utils/histogram.py
create mode 100644 sdks/python/apache_beam/utils/histogram_test.py
