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 3216fcb (commit)
to e4e39e4 (commit)
from 3216fcb Merge pull request #14412 from [BEAM-8696] protobuf-java
3.14.0 in line with libraries BOM 16.3.0
add b8ff868 [BEAM-12095] Add unit tests for path_to_beam_jar(artifact_id).
add b183b9a Merge pull request #14448: [BEAM-12095] Add unit tests for
path_to_beam_jar(artifact_id)
add 86ac487 [BEAM-11961] InfluxDBIOIT failing with unauthorized error
(#14215)
add e3d2654 [BEAM-12066] Bump classgraph to 4.8.104
add 968abf4 Merge pull request #14443: [BEAM-12066] Bump classgraph to
4.8.104
add 3a64c55 [BEAM-10925] Java UDF type tests for input refs.
add 1bde592 Merge pull request #14433 from ibzib/java-udf-types
add b1891ee Add DataFrame API changes to CHANGES.md (#14454)
add 6e1ce71 [BEAM-12102] Catch and rethrow Calcite CannotPlanException.
add bb7c427 Merge pull request #14447 from ibzib/BEAM-12102
add 2f3dfda Fix: Allow BigQuery tableIds with hyphens (#14125)
add 79546be Merge pull request #14394 from [BEAM-11277] Add method to
check if two TableSchema are equal
add 84b2d01 Update WriteToBigQuery multiple destinations doc
add eb3d693 Merge pull request #14280 from Update WriteToBigQuery
multiple destinations doc
add faa3c0b [BEAM-11900] Bump libthrift to 0.14.0
add 2fa6080 [BEAM-11900] Bump libthrift to 0.14.1
add a8cd059 Merge pull request #14153 from [BEAM-11900] Bump libthrift to
0.14.1
add 68a8625 [BEAM-449] Support PCollectionList in PAssert (#14322)
add c97e17e [BEAM-11742] Use pyarrow schema instead column names when
creating record batch in ParquetSink (#14335)
add 31efffe [BEAM-11045] Avoid broken deps
add 33cd75f Merge pull request #14465 from KevinGG/BEAM-11045
add 5ddae82 [BEAM-10708] Read/Write Intermediate PCollections
add e45705d Fix lint
add 0e9d4f9 Fix based on comments
add 6d26c75 Added clear method to InMemoryCache because tests might be
flaky when a clear is issued in recording manager tests.
add 719318b Avoid using interactive_environment module in the test
because ie.current_env() is raced by threads/processes in the test environment
on Jenkins.
add dd87e14 Added back the setUp as additional cleanup routine before
each test.
add e4e39e4 Merge pull request #14368 from KevinGG/portable_pin_2
No new revisions were added by this update.
Summary of changes:
.test-infra/kubernetes/influxdb/influxdb.yml | 4 +-
CHANGES.md | 3 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../java/org/apache/beam/sdk/testing/PAssert.java | 71 ++++++++
.../org/apache/beam/sdk/testing/PAssertTest.java | 144 +++++++++++++++
.../sql/zetasql/ZetaSQLQueryPlanner.java | 11 +-
.../extensions/sql/zetasql/ZetaSqlJavaUdfTest.java | 7 +-
.../sql/zetasql/ZetaSqlJavaUdfTypeTest.java | 201 ++++++++++++++++++++-
sdks/java/io/thrift/build.gradle | 2 +-
.../org/apache/beam/sdk/io/thrift/ThriftCoder.java | 6 +-
.../org/apache/beam/sdk/io/thrift/ThriftIO.java | 9 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 4 +-
.../apache_beam/io/gcp/bigquery_file_loads.py | 8 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 77 +++++++-
.../apache_beam/io/gcp/bigquery_tools_test.py | 94 ++++++++++
sdks/python/apache_beam/io/parquetio.py | 4 +-
sdks/python/apache_beam/io/parquetio_test.py | 24 ++-
.../runners/interactive/augmented_pipeline.py | 132 ++++++++++++++
.../runners/interactive/augmented_pipeline_test.py | 86 +++++++++
.../runners/interactive/caching/read_cache.py | 148 +++++++++++++++
.../runners/interactive/caching/read_cache_test.py | 91 ++++++++++
.../runners/interactive/caching/write_cache.py | 188 +++++++++++++++++++
.../interactive/caching/write_cache_test.py | 85 +++++++++
.../testing/integration/notebook_executor.py | 3 +-
.../integration/tests/init_square_cube_test.py | 3 +
.../interactive/testing/test_cache_manager.py | 4 +
.../apache_beam/utils/subprocess_server_test.py | 22 +++
sdks/python/scripts/generate_pydoc.sh | 2 +
sdks/python/setup.py | 4 +-
29 files changed, 1402 insertions(+), 37 deletions(-)
create mode 100644
sdks/python/apache_beam/runners/interactive/augmented_pipeline.py
create mode 100644
sdks/python/apache_beam/runners/interactive/augmented_pipeline_test.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/read_cache.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/read_cache_test.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/write_cache.py
create mode 100644
sdks/python/apache_beam/runners/interactive/caching/write_cache_test.py
