问题标签 [dse-graph-frames]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
48 浏览

apache-spark - Java中的DseGraphFrame是否支持导出图形?

根据DSE 文档,顶点和边可以导出调用g.V().hasLabel("Person").write.json("/tmp/person_v_json")dse spark

DseGraphFrame使用Java SDK可以实现同样的效果吗?我想确定,因为我找不到write()方法。

0 投票
1 回答
45 浏览

datastax-enterprise - 使用带有查询时间戳字段的 DseGraphFrame 时出错

我有一个定义了属性的Person标签created

尝试使用 DseGraphFrame 使用以下created属性过滤 Person 标签时出现以下错误dse spark

scala> gV().hasLabel("Person").has("created", P.gt("2018-10-07T14:46:26.790Z")).count().next()

org.apache.spark.sql.AnalysisException:由于数据类型不匹配,无法解析“(created> 1538923586790L)”:“(created> 1538923586790L)”(时间戳和bigint)中的类型不同。; 'Filter ((~label#270 = Person) && (created#280 > 1538923586790))...</p>

知道为什么吗?

0 投票
1 回答
260 浏览

apache-spark - 无法使用 Spark 在 Datastax 上初始化图形

我正在尝试使用 Spark 初始化我的 Datastax 图,如下所示:

但我有以下例外:

我搜索了一个包含com/datastax/bdp/graph/impl但没有找到的 dataxtax jar。

非常感谢任何帮助。提前致谢!

0 投票
1 回答
262 浏览

gremlin - 使用 Spark 添加 Edges gremlin

当我使用 spark 时,我无法保存我的优势,如下所示:有关信息,它可以通过使用 gremlin 控制台来保存优势

当我尝试时:graph.edges.show() 我得到一张空桌子

0 投票
1 回答
108 浏览

scala - 启动图形时出错 (DSEGraphFrame )

我在验证/产品环境中有一个 dse 图。当我尝试在 Scala 中使用 Spark 启动 DSEGraphFrame 查询时,会出现问题。

生成以下异常:

线程“主”com.datastax.driver.core.exceptions.InvalidQueryException 中的异常:方法 DseGraphRpc.getSchemaBlob 不存在。确保该方法所需的组件在 com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java 的 com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:40) 处处于活动状态/启用状态:26) 在 com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:284) 在 com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:49) 在 sun.reflect.NativeMethodAccessorImpl.invoke0(本机方法)在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.

我该怎么做才能正确运行 DSEGraphFrame?

0 投票
1 回答
47 浏览

cassandra - 我有三个节点的 dse 图集群。启用两个节点图一个是启用搜索。问题是当我运行 api 请求时它没有响应

我有三节点 dse Cassandra 集群。一个节点启用搜索,两个节点启用图形。当我运行 API(在 scala play 框架中编码)时,POST 或 GET 请求不断进行,它确实给出了响应。Cassandra 的日志中没有任何信息,它工作正常。

早些时候我曾经使用启用图形的单节点集群。

0 投票
1 回答
47 浏览

apache-spark - 如何使用 DseGraphFrame 基于特定遍历导出 Datastax 图

我想通过火花作业导出 DSE 图,按照 https://docs.datastax.com/en/dse/6.0/dse-dev/datastax_enterprise/graph/graphAnalytics/dseGraphFrameExport.html

所有这些在 spark-shell 中都可以正常工作,我想在 Java 中使用 DseGraphFrame 来执行此操作。不幸的是,文档中没有太多内容

我可以用以下代码打包一个罐子并做一个 spark-submit

以上工作正常,我想做的是使用特定的遍历来过滤我导出的内容。那就是使用类似的东西

以上不起作用,因为dseGraphFrame.V().hasLabel("label")没有.df()

这是正确的做事方式吗

任何帮助,将不胜感激

0 投票
0 回答
86 浏览

gremlin - 使用 gremlin 测试和模拟 ScalaGraph

我有一个我正在尝试进行单元测试的服务类。服务等级如下——:

所以在测试这个类时,我创建了一个注入服务的模拟(BusinessService,GrDbConnection)-:

GrDbConnection.scala 具有定义的 db.g -:

这里的连接具有连接到实际数据库的必要细节。

因为我可以使用 Mockito.when().thenReturn() 返回一个空的 scala 图,所以我不想在我的测试类中使用 .configure() 选项。

我面临的真正问题是,我无法将顶点添加到测试图中,我需要将 btoModel 作为顶点添加到图中,因为在服务类中:

我该怎么做?请通过 - nilay0016@gmail.com 与我联系以获取更多信息。

0 投票
0 回答
65 浏览

datastax - 使用属性键加载 DataStax 图形加载器边缘的问题

DSE 版本 6.7 和 DSE 图形加载器版本 6.7

我们有两个顶点名称“x”和“y”,并且在 x 到 y 之间有一个名为“z”的连接边。那个边缘也有属性。所以我们也需要加载它。属性数据类型是 Txt(string),除了顶点分区键是 UUID。

正如 Datastax 的文档中提到的,要加载带有属性的边,我们需要 gzip CSV 。 https://docs.datastax.com/en/dse/6.7/dse-dev/datastax_enterprise/graph/dgl/dglMapScript.html 现在我们正在使用图形加载器加载数据,以加载和 x 和 y 之间的边。

这是我们的 groovy 脚本

这是我们的 csv 文件格式

xId 和 yId 是 UUID,除此之外,都是数据库中的 Text(string) 数据类型

现在我们使用 dse graph loader 运行那个 groovy 脚本,我们得到了这个错误

有什么解决方案吗?