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