Как использовать параллельный поток Java 8 для выполнения обхода и обработки графа neo4j
Я в настоящее время использую Neo4j Graph Database. Я пытаюсь пройти узлы, начиная с startNode параллельно. Ниже приведен код:
neo4jDb.getTraversalDescription().depthFirst().
relationships(RelationshipType.withName("R1"),Direction.OUTGOING).traverse(startNode).nodes().stream().parallel().foreach(node->{Transaction tx = neo4j.beginTX();//perform some operation on each node.
tx.success();});
Это выдает ошибку: Запрошенная операция не может быть выполнена, потому что она должна быть выполнена в транзакции. Убедитесь, что вы помещаете свою операцию в соответствующий шаблон транзакции и попробуйте снова.
Как мне поступить?