问题标签 [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.
apache-spark - Java中的DseGraphFrame是否支持导出图形?
根据DSE 文档,顶点和边可以导出调用g.V().hasLabel("Person").write.json("/tmp/person_v_json")
。dse spark
DseGraphFrame
使用Java SDK可以实现同样的效果吗?我想确定,因为我找不到write()
方法。
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>
知道为什么吗?
apache-spark - 无法使用 Spark 在 Datastax 上初始化图形
我正在尝试使用 Spark 初始化我的 Datastax 图,如下所示:
但我有以下例外:
我搜索了一个包含com/datastax/bdp/graph/impl
但没有找到的 dataxtax jar。
非常感谢任何帮助。提前致谢!
gremlin - 使用 Spark 添加 Edges gremlin
当我使用 spark 时,我无法保存我的优势,如下所示:有关信息,它可以通过使用 gremlin 控制台来保存优势
当我尝试时:graph.edges.show()
我得到一张空桌子
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?
cassandra - 我有三个节点的 dse 图集群。启用两个节点图一个是启用搜索。问题是当我运行 api 请求时它没有响应
我有三节点 dse Cassandra 集群。一个节点启用搜索,两个节点启用图形。当我运行 API(在 scala play 框架中编码)时,POST 或 GET 请求不断进行,它确实给出了响应。Cassandra 的日志中没有任何信息,它工作正常。
早些时候我曾经使用启用图形的单节点集群。
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()
这是正确的做事方式吗
任何帮助,将不胜感激
gremlin - 使用 gremlin 测试和模拟 ScalaGraph
我有一个我正在尝试进行单元测试的服务类。服务等级如下——:
所以在测试这个类时,我创建了一个注入服务的模拟(BusinessService,GrDbConnection)-:
GrDbConnection.scala 具有定义的 db.g -:
这里的连接具有连接到实际数据库的必要细节。
因为我可以使用 Mockito.when().thenReturn() 返回一个空的 scala 图,所以我不想在我的测试类中使用 .configure() 选项。
我面临的真正问题是,我无法将顶点添加到测试图中,我需要将 btoModel 作为顶点添加到图中,因为在服务类中:
我该怎么做?请通过 - nilay0016@gmail.com 与我联系以获取更多信息。
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 脚本,我们得到了这个错误
有什么解决方案吗?