小编use*_*709的帖子

spark graphx:如何遍历图形以创建二度邻居的图形

我是初学者,有火花/ hadoop /图形计算,所以请原谅我的初学者问题.

我使用graphx创建了一个图表.现在,对于每个顶点,我想得到它的所有二阶邻居.所以,如果我的图表是:

v1 --> v2
v1 --> v4
v1 --> v6
Run Code Online (Sandbox Code Playgroud)

我希望得到类似的东西:

v2 --> v4
v2 --> v6
v4 --> v2
v4 --> v6
v6 --> v2
v6 --> v4
Run Code Online (Sandbox Code Playgroud)

我的图表非常大,所以我希望尽可能优雅高效地完成.

我有一种感觉,这不应该太难,但作为这个巨大框架的一个全新的东西,我发现自己遍布文档/来源试图弄清楚这个.

有没有人对图形实例的最佳方法有什么建议?

谢谢!

apache-spark

10
推荐指数
1
解决办法
4418
查看次数

如何在查询参数中喷射解组列表

我是新来的喷雾剂.我正在玩构建路由,虽然我设法使用参数指令从查询字符串中获取参数,但是当我希望其中一个参数成为列表时,我遇到了麻烦.

对于这个例子,我已经定义了这个案例类:

case class Person(name: String, friends: Int)
Run Code Online (Sandbox Code Playgroud)

我的路线目前看起来像这样:

path("test") { 
    get { parameters('name, 'friend ).as(Person) { p => complete(p) } }
}
Run Code Online (Sandbox Code Playgroud)

这工作正常,我可以做一个get:localhost:8080/test?name = jo&friends = 12并得到我的期望.

我想传递朋友ID的列表,而不仅仅是朋友的数量,所以我开始更改我的案例类,如下所示:

case class Person(name: String, friends: Array[Int])
Run Code Online (Sandbox Code Playgroud)

我的电话:localhost:8080/test?name = jo&friends = 1,2

这不编译.我得到一个类型不匹配:发现:Person.type required:spray.routing.HListDeserializer [shapeless.:: [String,shapeless.:: [String,shapeless.HNil]],?] get {parameters('name,'friend) ).as(Person){p => ^ comment:这指向P in .as(Person)

关于我做错了什么的任何想法?我喜欢这个怎么做的答案.更好的是解释它正在寻找的这种无形类型.谢谢

scala routes spray spray-dsl

5
推荐指数
1
解决办法
1338
查看次数

标签 统计

apache-spark ×1

routes ×1

scala ×1

spray ×1

spray-dsl ×1