You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/01/16 03:41:52 UTC
[beam] tag nightly-master updated (6675586 -> b50e951)
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 6675586 (commit)
to b50e951 (commit)
from 6675586 [BEAM-11637] Use accumulators properly in BitAnd. (#13745)
add 0f36a72 [BEAM-11622]Change the input type of FHIR Search to KV<String, Map<String, Object>> (#13726)
add cff7fc6 [BEAM-11497] Avoid zerodivision error in custom BQ source
add 4bdafec Merge pull request #13734 from [BEAM-11497] Avoid zerodivision error in custom BQ source
add c9004b2 feat: Add partition increase handling to PubsubLiteIO
add b109e21 fix: Ensure manually set partitions are not ignored.
add 3ca4360 fix: Format
add 1db9ec3 fix: Format
add 49c5ed0 fix: Remove guava usage.
add 6a70085 fix: docs
add 343a847 Merge pull request #13567 from [BEAM-10114] Add partition increase handling to PubsubLiteIO
add aab4353 Fix translate.go to prevent panic (#13720)
add b50e951 [BEAM-11533] Support DATE, TIME, DATETIME in PubSub (#13751)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 6 +-
.../java/org/apache/beam/sdk/util/RowJson.java | 51 +++++++++--
.../beam/sdk/util/RowJsonValueExtractors.java | 39 ++++++++
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 45 ++++++---
.../sdk/io/gcp/healthcare/HealthcareApiClient.java | 2 +-
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 12 +--
.../sdk/io/gcp/pubsublite/SubscribeTransform.java | 40 ++++++--
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 30 +-----
.../pubsublite/SubscriptionPartitionLoader.java | 102 +++++++++++++++++++++
.../beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 83 ++++++++++++++---
.../beam/sdk/io/gcp/healthcare/FhirIOTest.java | 24 +++++
.../SubscriptionPartitionLoaderTest.java | 84 +++++++++++++++++
sdks/python/apache_beam/io/gcp/bigquery.py | 2 +-
13 files changed, 439 insertions(+), 81 deletions(-)
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoaderTest.java