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 2020/12/01 03:06:34 UTC
[beam] tag nightly-master updated (372a4f3 -> eb11a3f)
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 372a4f3 (commit)
to eb11a3f (commit)
from 372a4f3 Merge pull request #13427: [BEAM-11343] Make ExpansionServiceClient accesible outside of core-construction-java
add d1ff41d [BEAM-7003 BEAM-8639 BEAM-8774] Update Kafka dependencies and add tests for the previous versions
add 4ba51cd Merge pull request #13026: [BEAM-7003 BEAM-8639 BEAM-8774] Update Kafka dependencies, enable IT test in Postcommit
add 3d23f47 Warn if temp dataset cleanup permission is denied
add bee6602 Merge pull request #13433 from Warn if temp dataset cleanup permission is denied
add a1fac1d Merge pull request #13170 from [BEAM-9650] Adding support for ReadAll from BigQuery transform
add 978b812 Merge pull request #13137 from [BEAM-11073] Dicom IO Connector for Java
add 40f517f Fixes silent fail in bigtableio.py by logging ImportError (#13332)
add fb62dd8 spotlessApply
add d85b62f Merge pull request #13445: [BEAM-11343] Run spotlessApply
add 1e63259 Update quickstart-py.md
add 4382a40 Update website/www/site/content/en/get-started/quickstart-py.md
add 47a5808 Update the other version reference
add 5e9237c [BEAM-7372] Update python version support in Python quickstart (#13442)
add 14b4889 Revert "Add use_unified_worker to pipeline options."
add eb11a3f Merge pull request #13446 from Revert "Add use_unified_worker to pipeline options."
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
build.gradle | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 5 +-
.../beam/runners/core/construction/External.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/DicomIO.java | 199 ++++++++++++++
.../sdk/io/gcp/healthcare/HealthcareApiClient.java | 12 +
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 79 ++++++
.../beam/sdk/io/gcp/healthcare/WebPathParser.java | 63 +++++
.../beam/sdk/io/gcp/healthcare/DicomIOReadIT.java | 91 +++++++
.../beam/sdk/io/gcp/healthcare/DicomIOTest.java} | 44 ++--
.../sdk/io/gcp/healthcare/WebPathParserTest.java | 41 +--
.../src/test/resources/DICOM/testDicomFile.dcm | Bin 0 -> 10366 bytes
sdks/java/io/kafka/build.gradle | 90 +++++--
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 69 ++++-
.../apache_beam/examples/kafkataxi/README.md | 4 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 268 +++++++++++++------
.../apache_beam/io/gcp/bigquery_read_internal.py | 289 +++++++++++++++++++++
.../apache_beam/io/gcp/bigquery_read_it_test.py | 103 ++++++++
sdks/python/apache_beam/io/gcp/bigquery_test.py | 2 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 12 +-
sdks/python/apache_beam/io/gcp/bigtableio.py | 7 +-
sdks/python/apache_beam/io/iobase.py | 13 +-
.../site/content/en/get-started/quickstart-py.md | 4 +-
23 files changed, 1235 insertions(+), 164 deletions(-)
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/DicomIO.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/WebPathParser.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/DicomIOReadIT.java
copy sdks/java/{core/src/test/java/org/apache/beam/sdk/transforms/DoFnTest.java => io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/DicomIOTest.java} (52%)
copy runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/apiary/ApiaryTest.java => sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/WebPathParserTest.java (50%)
create mode 100644 sdks/java/io/google-cloud-platform/src/test/resources/DICOM/testDicomFile.dcm