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
