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 (e542d1f -> 3e933b5)
Date Thu, 15 Jul 2021 03:22:55 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 e542d1f  (commit)
      to 3e933b5  (commit)
    from e542d1f  [BEAM-12556] Enable Go Build Tests in Samza Runner (#15167)
     add 947cbb7  [BEAM-8376] Google Cloud Firestore Connector - Add Firestore v1 Read Operations
(#15005)
     add 76ee783  Misc Fixes
     add 3f3a7fb  Merge pull request #15163 from KevinGG/fix_dep
     add 0866bff  [BEAM-12611] Add Instruction ID to LogEntry, by introducing BeamFnLoggingMDC
to propagate the instruction id with a ThreadLocal (#15166)
     add 97cf94c  Updated screendiff golden screenshots for Linux platforms.
     add 3e933b5  Merge pull request #15171 from KevinGG/fix_dep

No new revisions were added by this update.

Summary of changes:
 .../fn/harness/control/ProcessBundleHandler.java   |    4 +
 .../fn/harness/logging/BeamFnLoggingClient.java    |    5 +
 .../beam/fn/harness/logging/BeamFnLoggingMDC.java} |   21 +-
 .../harness/logging/BeamFnLoggingClientTest.java   |    8 +-
 .../harness/logging/RestoreBeamFnLoggingMDC.java   |   18 +-
 .../logging/RestoreBeamFnLoggingMDCTest.java       |   36 +-
 .../beam/sdk/io/gcp/firestore/FirestoreDoFn.java   |   30 +-
 .../FirestoreStatefulComponentFactory.java         |   12 +-
 .../beam/sdk/io/gcp/firestore/FirestoreV1.java     | 1103 +++++++++++++++++++-
 .../sdk/io/gcp/firestore/FirestoreV1ReadFn.java    |  632 +++++++++++
 ...1Fn.java => FirestoreV1RpcAttemptContexts.java} |    8 +-
 .../sdk/io/gcp/firestore/FirestoreV1WriteFn.java   |   13 +-
 .../apache/beam/sdk/io/gcp/firestore/RpcQos.java   |    8 +-
 .../beam/sdk/io/gcp/firestore/RpcQosImpl.java      |  253 ++++-
 .../beam/sdk/io/gcp/firestore/RpcQosOptions.java   |    2 +-
 .../io/gcp/firestore/BaseFirestoreV1FnTest.java    |   29 +-
 .../gcp/firestore/BaseFirestoreV1ReadFnTest.java   |  149 +++
 .../gcp/firestore/BaseFirestoreV1WriteFnTest.java  |   26 +-
 .../FirestoreV1FnBatchGetDocumentsTest.java        |  246 +++++
 .../FirestoreV1FnListCollectionIdsTest.java        |  216 ++++
 .../firestore/FirestoreV1FnListDocumentsTest.java  |  263 +++++
 .../firestore/FirestoreV1FnPartitionQueryTest.java |  228 ++++
 .../gcp/firestore/FirestoreV1FnRunQueryTest.java   |  364 +++++++
 ...artitionQueryResponseToRunQueryRequestTest.java |  141 +++
 .../beam/sdk/io/gcp/firestore/RpcQosTest.java      |   71 +-
 .../sdk/io/gcp/firestore/it/BaseFirestoreIT.java   |  184 ++++
 .../sdk/io/gcp/firestore/it/FirestoreV1IT.java     |  190 ++++
 .../29c9237ddf4f3d5988a503069b4d3c47.png           |  Bin 64591 -> 67298 bytes
 .../Darwin/7a35f487b2a5f3a9b9852a8659eeb4bd.png    |  Bin 748019 -> 760584 bytes
 .../Linux/29c9237ddf4f3d5988a503069b4d3c47.png     |  Bin 64591 -> 65511 bytes
 .../Linux/7a35f487b2a5f3a9b9852a8659eeb4bd.png     |  Bin 679724 -> 728121 bytes
 .../{screen_diff_tests.py => screen_diff_test.py}  |   14 +-
 sdks/python/container/base_image_requirements.txt  |    2 +-
 33 files changed, 4127 insertions(+), 149 deletions(-)
 copy sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/SqlConversionException.java
=> harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingMDC.java} (58%)
 copy runners/spark/src/test/java/org/apache/beam/runners/spark/ClearWatermarksRule.java =>
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/logging/RestoreBeamFnLoggingMDC.java
(65%)
 copy runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/testing/RestoreDataflowLoggingMDCTest.java
=> sdks/java/harness/src/test/java/org/apache/beam/fn/harness/logging/RestoreBeamFnLoggingMDCTest.java
(51%)
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1ReadFn.java
 rename sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/{FirestoreV1Fn.java
=> FirestoreV1RpcAttemptContexts.java} (92%)
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/BaseFirestoreV1ReadFnTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnBatchGetDocumentsTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnListCollectionIdsTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnListDocumentsTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnPartitionQueryTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1FnRunQueryTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/PartitionQueryResponseToRunQueryRequestTest.java
 copy sdks/python/apache_beam/runners/interactive/testing/integration/goldens/{Linux =>
Darwin}/29c9237ddf4f3d5988a503069b4d3c47.png (58%)
 rename sdks/python/apache_beam/runners/interactive/testing/integration/tests/{screen_diff_tests.py
=> screen_diff_test.py} (81%)

Mime
View raw message