You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2021/07/01 07:40:00 UTC

[jira] [Work logged] (BEAM-12400) Improve MongoDBIO for beam - add update capability

     [ https://issues.apache.org/jira/browse/BEAM-12400?focusedWorklogId=617444&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-617444 ]

ASF GitHub Bot logged work on BEAM-12400:
-----------------------------------------

                Author: ASF GitHub Bot
            Created on: 01/Jul/21 07:39
            Start Date: 01/Jul/21 07:39
    Worklog Time Spent: 10m 
      Work Description: pareshsarafmdb commented on a change in pull request #14927:
URL: https://github.com/apache/beam/pull/14927#discussion_r662054322



##########
File path: sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java
##########
@@ -106,6 +109,28 @@
  *     .withNumSplits(30))
  *
  * }</pre>
+ *
+ * *
+ *
+ * <p>To configure a MongoDB sink and update, you must specify a connection {@code URI}, a {@code
+ * Database} * name, a {@code Collection} name. It matches the key with _id in target collection.
+ * For instance: * *
+ *
+ * <pre>{@code
+ * * pipeline
+ * *   .apply(...)
+ * *   .apply(MongoDbIO.write()
+ * *     .withUri("mongodb://localhost:27017")
+ * *     .withDatabase("my-database")
+ * *     .withCollection("my-collection")
+ * *     .withIsUpdate(true)
+ * *     .withUpdateKey("key-to-match")
+ * *     .withUpdateField("field-to-update")
+ * *     .withUpdateOperator("$set")
+ * *     .withNumSplits(30))

Review comment:
       Yeah. Have implemented most of it. Testing it now. 




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Issue Time Tracking
-------------------

            Worklog Id:     (was: 617444)
    Remaining Estimate: 166h 20m  (was: 166.5h)
            Time Spent: 1h 40m  (was: 1.5h)

> Improve MongoDBIO for beam - add update capability
> --------------------------------------------------
>
>                 Key: BEAM-12400
>                 URL: https://issues.apache.org/jira/browse/BEAM-12400
>             Project: Beam
>          Issue Type: Improvement
>          Components: io-java-mongodb
>            Reporter: Paresh Saraf
>            Assignee: Paresh Saraf
>            Priority: P2
>   Original Estimate: 168h
>          Time Spent: 1h 40m
>  Remaining Estimate: 166h 20m
>
> Right now mongodbio supports only inserts/overwrites to a collections. In many cases it will be usually updating an existing document: setting a field or pushing into an array. BulkUpdate capability to be added as part part of MongoDBIo->Write



--
This message was sent by Atlassian Jira
(v8.3.4#803005)