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 302de87 (commit)
to f23ebad (commit)
from 302de87 Workaround for incremental in read_json. (#13489)
add dc7ecb9 [BEAM-9196] Update testcontainers to 1.15.1
add fc42781 Merge pull request #13530: [BEAM-9196] Update testcontainers
to 1.15.1
add 82bbdf7 [BEAM-10124] Add missing announcement from CHANGES.md (#13537)
add 38d3c5d [BEAM-11075] Enable Go load tests for Dataflow (#13529)
add 755eab2 [BEAM-11338] Addendum: handle private fields in generated
thrift code (#13539)
add 7e85cc7 Add output type hints for GroupIntoBatches. (#13493)
add 7bdc297 [BEAM-11444] Python IO MongoDB: mask password in display_data
uri and spec. (#13541)
add 18b0ee8 Change the output type of FHIR Search from String to
JsonArray (#13516)
add 8649972 [BEAM-11429] User-friendly names for packed combiners (#13535)
add be85be2 [Beam-11438] start-build-env.sh improve for macOS (#13545)
add 34ae21b [BEAM-11065] Apache Beam pipeline example to ingest from
Apache Kafka to Google Pub/Sub (#13112)
add 52a2270 [BEAM-11196] Fix `None` parent when fusing >2 stages (#13549)
add f23ebad [BEAM-10641] Add Combiner Packing to Dataflow (#13455)
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/README.md | 9 +-
.../jenkins/job_LoadTests_Combine_Flink_Go.groovy | 2 +-
...k_Go.groovy => job_LoadTests_Combine_Go.groovy} | 85 +++-----
.../jenkins/job_LoadTests_GBK_Flink_Go.groovy | 2 +-
.test-infra/jenkins/job_LoadTests_GBK_Go.groovy | 211 ++++++++++++++++++
.test-infra/jenkins/job_LoadTests_ParDo_Go.groovy | 145 +++++++++++++
.test-infra/jenkins/job_LoadTests_coGBK_Go.groovy | 169 +++++++++++++++
CHANGES.md | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
examples/java/build.gradle | 9 +-
.../org/apache/beam/examples/complete/README.md | 5 +
.../kafkatopubsub/KafkaPubsubConstants.java | 29 +++
.../complete/kafkatopubsub/KafkaToPubsub.java | 235 +++++++++++++++++++++
.../beam/examples/complete/kafkatopubsub/README.md | 200 ++++++++++++++++++
.../complete/kafkatopubsub/avro/AvroDataClass.java | 63 ++++++
.../avro/AvroDataClassKafkaAvroDeserializer.java | 45 ++--
.../complete/kafkatopubsub/avro/package-info.java | 20 ++
.../kafka/consumer/SslConsumerFactoryFn.java | 130 ++++++++++++
.../kafkatopubsub/kafka/consumer/Utils.java | 165 +++++++++++++++
.../kafkatopubsub/kafka/consumer/package-info.java | 20 ++
.../options/KafkaToPubsubOptions.java | 90 ++++++++
.../kafkatopubsub/options/package-info.java | 20 ++
.../complete/kafkatopubsub/package-info.java | 20 ++
.../kafkatopubsub/transforms/FormatTransform.java | 127 +++++++++++
.../kafkatopubsub/transforms/package-info.java | 20 ++
.../complete/kafkatopubsub/KafkaToPubsubTest.java | 90 ++++++++
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 14 +-
.../beam/sdk/io/gcp/healthcare/JsonArrayCoder.java | 48 +++++
.../beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 7 +-
.../beam/sdk/io/gcp/healthcare/FhirIOTest.java | 3 +-
.../apache/beam/sdk/io/thrift/ThriftSchema.java | 2 +-
.../apache/beam/sdk/io/thrift/TestThriftEnum.java | 2 +-
.../beam/sdk/io/thrift/TestThriftInnerStruct.java | 14 +-
.../beam/sdk/io/thrift/TestThriftStruct.java | 77 +++----
.../apache/beam/sdk/io/thrift/TestThriftUnion.java | 2 +-
.../apache/beam/sdk/io/thrift/ThriftIOTest.java | 38 ++--
.../src/test/resources/thrift/thrift_test.thrift | 11 +-
sdks/python/apache_beam/coders/coders.py | 2 +-
sdks/python/apache_beam/io/mongodbio.py | 29 ++-
sdks/python/apache_beam/io/mongodbio_test.py | 41 ++++
.../runners/dataflow/dataflow_runner.py | 16 ++
.../portability/fn_api_runner/translations.py | 81 +++++--
.../portability/fn_api_runner/translations_test.py | 18 +-
sdks/python/apache_beam/transforms/util.py | 12 +-
sdks/python/apache_beam/transforms/util_test.py | 24 +++
.../apache_beam/typehints/sharded_key_type.py | 31 ++-
.../apache_beam/typehints/sharded_key_type_test.py | 35 +--
start-build-env.sh | 16 +-
website/www/site/content/en/blog/beam-2.26.0.md | 1 +
49 files changed, 2206 insertions(+), 233 deletions(-)
copy .test-infra/jenkins/{job_LoadTests_Combine_Flink_Go.groovy =>
job_LoadTests_Combine_Go.groovy} (56%)
create mode 100644 .test-infra/jenkins/job_LoadTests_GBK_Go.groovy
create mode 100644 .test-infra/jenkins/job_LoadTests_ParDo_Go.groovy
create mode 100644 .test-infra/jenkins/job_LoadTests_coGBK_Go.groovy
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaPubsubConstants.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsub.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/README.md
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/AvroDataClass.java
copy
sdks/java/io/thrift/src/test/java/org/apache/beam/sdk/io/thrift/TestThriftEnum.java
=>
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/AvroDataClassKafkaAvroDeserializer.java
(50%)
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/package-info.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/SslConsumerFactoryFn.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/Utils.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/package-info.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/options/KafkaToPubsubOptions.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/options/package-info.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/package-info.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/transforms/FormatTransform.java
create mode 100644
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/transforms/package-info.java
create mode 100644
examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/JsonArrayCoder.java
