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 31716b0 (commit)
to 5caeb5d (commit)
from 31716b0 [BEAM-7372] Remove some py 2 and 3.5 references from the
website (#13500)
add ce69ec6 [BEAM-11312] Minor improvement in retrieving build log
(#13501)
add 196fd9d [BEAM-11207] Return valid error on job failures (#13484)
add 0498a17 [BEAM-11413] Fix default job server for Spark tests.
add 7b39702 Merge pull request #13498 from ibzib/BEAM-11413
add 80eff6c [BEAM-11417] Use Cache with time eviction policy for
commitCallbacks
add a9a1c8e Merge pull request #13507 from [BEAM-11417] Use Cache with
time eviction policy for commitCallbacks
add bbaaeb0 Decode data channel elements after, rather than before,
placing them in the queue. (#13387)
add 5caeb5d Merge pull request #13395 from [BEAM-11426] Add FHIR Search
to io/gcp/healthcare/FhirIO
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/StreamingDataflowWorker.java | 12 +-
.../worker/fn/data/BeamFnDataGrpcService.java | 14 +-
.../runners/fnexecution/data/GrpcDataService.java | 6 +-
.../beam/runners/universal/runnerlib/execute.go | 13 +-
.../sdk/fn/data/BeamFnDataInboundObserver.java | 35 +---
.../beam/sdk/fn/data/DecodingFnDataReceiver.java | 35 ++--
.../beam/fn/harness/data/BeamFnDataClient.java | 14 +-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 10 +-
.../fn/harness/data/QueueingBeamFnDataClient.java | 11 +-
.../data/BeamFnDataInboundObserverTest.java | 11 +-
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 232 +++++++++++++++++++++
.../sdk/io/gcp/healthcare/HealthcareApiClient.java | 17 ++
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 174 ++++++++++++++++
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 3 +-
.../beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 155 ++++++++++++++
.../beam/sdk/io/gcp/healthcare/FhirIOTest.java | 20 ++
.../runners/portability/sdk_container_builder.py | 11 +-
.../runners/portability/spark_runner_test.py | 2 +-
18 files changed, 688 insertions(+), 87 deletions(-)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillComputationKey.java
=>
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DecodingFnDataReceiver.java
(51%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java
