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/06/20 03:18:25 UTC
[beam] tag nightly-master updated (c53118c -> c986168)

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 c53118c  (commit)
      to c986168  (commit)
    from c53118c  Minor: Fix WontImplementMethod typo (#15018)
     add c986168  [BEAM-11289] [Java] Integrate Google Cloud Recommendations AI functionality

No new revisions were added by this update.

Summary of changes:
 sdks/java/extensions/ml/build.gradle               |  12 ++
 .../ml/RecommendationAICreateCatalogItem.java      | 134 +++++++++++++
 .../beam/sdk/extensions/ml/RecommendationAIIO.java |  51 +++++
 .../ml/RecommendationAIImportCatalogItems.java     | 200 +++++++++++++++++++
 .../ml/RecommendationAIImportUserEvents.java       | 216 +++++++++++++++++++++
 .../sdk/extensions/ml/RecommendationAIPredict.java | 156 +++++++++++++++
 .../ml/RecommendationAIWriteUserEvent.java         | 146 ++++++++++++++
 .../sdk/extensions/ml/DelegatingAtomicCoder.java}  |  36 ++--
 .../beam/sdk/extensions/ml/GenericJsonCoder.java   |  64 ++++++
 .../ml/RecommendationAICatalogItemIT.java          | 119 ++++++++++++
 .../extensions/ml/RecommendationAIPredictIT.java   |  80 ++++++++
 .../extensions/ml/RecommendationAIUserEventIT.java | 111 +++++++++++
 12 files changed, 1309 insertions(+), 16 deletions(-)
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAICreateCatalogItem.java
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAIIO.java
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAIImportCatalogItems.java
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAIImportUserEvents.java
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAIPredict.java
 create mode 100644 sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/RecommendationAIWriteUserEvent.java
 copy sdks/java/{io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidCoder.java => extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/DelegatingAtomicCoder.java} (54%)
 create mode 100644 sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/GenericJsonCoder.java
 create mode 100644 sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAICatalogItemIT.java
 create mode 100644 sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAIPredictIT.java
 create mode 100644 sdks/java/extensions/ml/src/test/java/org/apache/beam/sdk/extensions/ml/RecommendationAIUserEventIT.java