beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (6675586 -> b50e951)
Date Sat, 16 Jan 2021 03:41:52 GMT
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


Mime
View raw message