2017-04-27 77 views
0

当我把这叫做:如何正确调用apoc.map.groupBy()?

MATCH (node:Wallet) 
WITH collect(node) AS nodes 
CALL apoc.algo.pageRankWithConfig(nodes,{types:'SendTo'}) YIELD node, score 
WITH nodes, collect({id:toString(id(node)),score:score}) as ranks 
call apoc.map.groupBy(ranks,'id') as ranksById 
CALL apoc.algo.closeness(['SendTo'],nodes,'INCOMING') YIELD node, score 
RETURN node, ranksById[toString(id(node))] as rank, score 

引发此错误:

Invalid input 'a': expected whitespace, comment, result fields of a procedure, LOAD CSV, START, MATCH, UNWIND, MERGE, CREATE, SET, DELETE, REMOVE, FOREACH, WITH, CALL, RETURN, UNION, ';' or end of input (line 5, column 35 (offset: 224)) 
"call apoc.map.groupBy(ranks,'id') as ranksById" 
           ^

当我试图调用它是这样的:

MATCH (node:Wallet) 
WITH collect(node) AS nodes 
CALL apoc.algo.pageRankWithConfig(nodes,{types:'SendTo'}) YIELD node, score 
WITH nodes, collect({id:toString(id(node)),score:score}) as ranks 
call apoc.map.groupBy(ranks,'id') YIELD values 
CALL apoc.algo.closeness(['SendTo'],nodes,'INCOMING') YIELD node, score 
RETURN node, values[toString(id(node))] as rank, score 

的错误是: There is no procedure with the name `apoc.map.groupBy` registered for this database instance. Please ensure you've spelled the procedure name correctly and that the procedure is properly deployed.

当我用call apoc.help('apoc.map.groupBy'),该方法已注册,签名apoc.map.groupBy(values :: LIST? OF ANY?, key :: STRING?) :: (MAP?)

我该如何正确呼叫apoc.map.groupBy

回答

1

这是因为apoc.map.groupBy()是一个函数,而不是一个过程。 Neo4j 3.1引入了自定义的用户函数(可以作为表达式内联调用,不需要CALL或YIELD),因此很多过程被改为函数以获得更好的灵活性。

更改呼叫线是一个WITH,像这样:

WITH nodes, apoc.map.groupBy(ranks,'id') as values 
...