我是这个 cosmos Graph API 的新手。
这是我的用例。
- 获取 cosmosDB SQL 的更改提要文档并解析文档以便插入/更新到 cosmos GraphDB。
我尝试了火花更换馈电连接器。它正在使用 cosmos DB SQL 到 cosmos SQL Db。
我已经为每个写入流的作者实现了。
我正在使用 apache tinkerpop gremlin 查询。
无法用 scala 连接 spark 中的 tinkerpop 连接。
非常感谢任何建议/代码片段。
还有一个问题：
spark 更改 feed 连接器是否支持 java 版本的 spark 结构化流？