laglangyue commented on PR #400:
URL:
https://github.com/apache/incubator-pekko-connectors/pull/400#issuecomment-1923077250
I have read the official website documentation, and there are some changes
to client3 and client2
`Bucket ->document` (client2)
`Bucket ->scope ->collection` (client3)
And document and collection are not completely equivalent
For this API, jsonDocument will be changed to jsonObject，so api will be
change
```
/**
* Create a sink to update or insert a Couchbase
[[com.couchbase.client.java.document.JsonDocument JsonDocument]].
*/
def upsert(sessionSettings: CouchbaseSessionSettings,
writeSettings: CouchbaseWriteSettings,
bucketName: String): Sink[JsonDocument, Future[Done]] =
CouchbaseFlow.upsert(sessionSettings, writeSettings,
bucketName).toMat(Sink.ignore)(Keep.right)
```
And they provided scala sdk, my suggestion is to implement a connector based
on scala sdk.
@pjfanning @He-Pin how about using scala-sdk?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
