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 4861df4 (commit)
to efa5d80 (commit)
from 4861df4 Allow extension of SdkContainerImageBuilder (#13756)
add 62c304d [BEAM-11411] [BEAM-11410] Kafka to pub sub E2E test (#13636)
add a35d31f re-remove finalizedBy cleanup for docker container test
add 0dd6980 Merge pull request #13796 from [BEAM-11678] Fix Java
DataflowRunner test container cleanup
add a77818a feat: Allow Pub/Sub Lite Sink to support increasing partitions
add aa98bcf Merge pull request #13787 from [BEAM-10114] Allow Pub/Sub
Lite Sink to support increasing partitions
add c89799a Merge pull request #13786 from [BEAM-11686] Add
FhirSearchParameter class as input for FhirIO.Search.
add cec7f10 [BEAM-11665] Publish Beam GCP BOM (#13737)
add 5492d32 Merge pull request #1 from apache/master
add 2a4caf6 sync libraries-bom version
add 9bec672 Merge #13732: [BEAM-9444] sync Google libraries-bom version
add ae60a7b [BEAM-11581] Start ExecutionStateSampler in Java SDK harness
before dispatch loop.
add 390fb7e Merge pull request #13695 from [BEAM-11581] Start
ExecutionStateSampler in Java SDK harness before dispatch loop
add e1b42bf Merge pull request #12647 from [BEAM-10378] Deserializing
Azure Credentials
add 3d1f25a [BEAM-10112] Add more state and timer python examples to
website
add 89a5e3d Address comments
add 3a2a351 Render py
add 29b9542 Merge pull request #13591 from [BEAM-10112] Add more state
and timer python examples to website
add efc35c5 Revert "Merge pull request #12647 from [BEAM-10378]
Deserializing Azure Credentials"
add 15e2ad8 Merge pull request #13807 from pabloem/fix-azure
add efa5d80 Changing random to seconds since epoch to prevent BQ job name
colliss… (#13749)
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +-
examples/java/build.gradle | 4 +-
.../complete/kafkatopubsub/KafkaToPubsub.java | 10 +-
.../kafkatopubsub/kafka/consumer/Utils.java | 8 ++
.../options/KafkaToPubsubOptions.java | 6 +
.../kafkatopubsub/KafkaToPubsubE2ETest.java | 129 ++++++++++++++++++
release/build.gradle | 1 +
...oovy => GoogleCloudPlatformBomArchetype.groovy} | 17 +--
.../groovy/mobilegaming-java-dataflowbom.groovy | 61 +++++++++
release/src/main/scripts/run_rc_validation.sh | 11 ++
runners/google-cloud-dataflow-java/build.gradle | 10 +-
sdks/java/bom/build.gradle | 2 +-
sdks/java/bom/common.gradle | 128 ++++++++++++++++++
.../go => sdks/java/bom/gcp}/build.gradle | 22 ++-
.../java/org/apache/beam/fn/harness/FnHarness.java | 4 +
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 82 ++++++++---
.../sdk/io/gcp/healthcare/FhirSearchParameter.java | 89 ++++++++++++
.../gcp/healthcare/FhirSearchParameterCoder.java | 61 +++++++++
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 42 +++++-
.../beam/sdk/io/gcp/pubsublite/Publishers.java | 24 ++--
.../beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 65 +++------
.../beam/sdk/io/gcp/healthcare/FhirIOTest.java | 29 ++--
sdks/java/javadoc/build.gradle | 4 +-
.../maven-archetypes/examples/generate-sources.sh | 2 +-
.../maven-archetypes/gcp-bom-examples/build.gradle | 81 +++++++++++
.../{examples => gcp-bom-examples}/pom.xml | 8 +-
.../META-INF/maven/archetype-metadata.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 29 +---
sdks/python/apache_beam/io/gcp/bigquery.py | 6 +-
.../apache_beam/io/gcp/bigquery_read_internal.py | 3 +-
settings.gradle | 2 +
.../content/en/documentation/programming-guide.md | 150 +++++++++++++++++++--
33 files changed, 930 insertions(+), 166 deletions(-)
create mode 100644
examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
copy release/src/main/groovy/{StarterArchetype.groovy =>
GoogleCloudPlatformBomArchetype.groovy} (74%)
create mode 100644 release/src/main/groovy/mobilegaming-java-dataflowbom.groovy
create mode 100644 sdks/java/bom/common.gradle
copy {release/go-licenses/go => sdks/java/bom/gcp}/build.gradle (71%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameterCoder.java
create mode 100644 sdks/java/maven-archetypes/gcp-bom-examples/build.gradle
copy sdks/java/maven-archetypes/{examples => gcp-bom-examples}/pom.xml (94%)
copy sdks/java/maven-archetypes/{examples =>
gcp-bom-examples}/src/main/resources/META-INF/maven/archetype-metadata.xml (95%)
copy sdks/java/maven-archetypes/{examples =>
gcp-bom-examples}/src/main/resources/archetype-resources/pom.xml (93%)
