0

maxDepth が 3 の場合、コードは正常に実行されます。maxDepth = 4 の場合、このコードは td.traverse(start) への呼び出し (~ 38 行目) でハングし、次のようになります。

スレッド「メイン」での例外 java.lang.OutOfMemoryError: java.lang.AbstractStringBuilder.expandCapacity(AbstractStringBuilder.java:100) の java.util.Arrays.copyOf(Arrays.java:2882) の Java ヒープ スペース java.lang. AbstractStringBuilder.append(AbstractStringBuilder.java:515) at java.lang.StringBuilder.append(StringBuilder.java:189) at com.sun.jersey.core.util.ReaderWriter.readFromAsString(ReaderWriter.java:172) at com.sun .jersey.core.util.ReaderWriter.readFromAsString(ReaderWriter.java:157) at com.sun.jersey.core.provider.AbstractMessageReaderWriterProvider.readFromAsString(AbstractMessageReaderWriterProvider.java:114) at com.sun.jersey.core.impl.provider .entity.StringProvider.readFrom(StringProvider.java:73) at com.sun.jersey.core.impl.provider.entity.StringProvider.readFrom(StringProvider.java:58) com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:552) で com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:505) で org.neo4j.rest org.neo4j.rest.graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:138) の .graphdb.RequestResult.extractFrom(RequestResult.java:87) org.neo4j.rest.graphdb.ExecutingRestAPI.traverse(ExecutingRestAPI.java:486) ) org.neo4j.rest.graphdb.RestAPIFacade.traverse(RestAPIFacade.java:202) で org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) で com.tr.cmg.alloy。 dao.psd.RelationalPathSearchDAO.executeRelationalPathSearch(RelationalPathSearchDAO.java:38) at com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115)java:552) com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:505) で org.neo4j.rest.graphdb.RequestResult.extractFrom(RequestResult.java:87) で org.neo4j.rest .graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:138) org.neo4j.rest.graphdb.ExecutingRestAPI.traverse(ExecutingRestAPI.java:486) org.neo4j.rest.graphdb.RestAPIFacade.traverse(RestAPIFacade.java:202) ) org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) で com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.executeRelationalPathSearch(RelationalPathSearchDAO.java:38) で com.tr. cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115)java:552) com.sun.jersey.api.client.ClientResponse.getEntity(ClientResponse.java:505) で org.neo4j.rest.graphdb.RequestResult.extractFrom(RequestResult.java:87) で org.neo4j.rest .graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:138) org.neo4j.rest.graphdb.ExecutingRestAPI.traverse(ExecutingRestAPI.java:486) org.neo4j.rest.graphdb.RestAPIFacade.traverse(RestAPIFacade.java:202) ) org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) で com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.executeRelationalPathSearch(RelationalPathSearchDAO.java:38) で com.tr. cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115)org.neo4j.rest.graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:138) の extractFrom(RequestResult.java:87) org.neo4j.rest.graphdb.ExecutingRestAPI.traverse(ExecutingRestAPI.java:486) .rest.graphdb.RestAPIFacade.traverse(RestAPIFacade.java:202) at org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) at com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO .executeRelationalPathSearch(RelationalPathSearchDAO.java:38) com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115) でorg.neo4j.rest.graphdb.ExecutingRestRequest.post(ExecutingRestRequest.java:138) の extractFrom(RequestResult.java:87) org.neo4j.rest.graphdb.ExecutingRestAPI.traverse(ExecutingRestAPI.java:486) .rest.graphdb.RestAPIFacade.traverse(RestAPIFacade.java:202) at org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) at com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO .executeRelationalPathSearch(RelationalPathSearchDAO.java:38) com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115) で202) org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) で com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.executeRelationalPathSearch(RelationalPathSearchDAO.java:38) で com.tr .cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115)202) org.neo4j.rest.graphdb.traversal.RestTraversal.traverse(RestTraversal.java:162) で com.tr.cmg.alloy.dao.psd.RelationalPathSearchDAO.executeRelationalPathSearch(RelationalPathSearchDAO.java:38) で com.tr .cmg.alloy.dao.psd.RelationalPathSearchDAO.main(RelationalPathSearchDAO.java:115)

package com.tr.cmg.alloy.dao.psd;

import java.util.ArrayList;

import org.neo4j.graphdb.Direction;
import org.neo4j.graphdb.Node;
import org.neo4j.graphdb.Path;
import org.neo4j.graphdb.Relationship;
import org.neo4j.graphdb.traversal.TraversalDescription;
import org.neo4j.rest.graphdb.index.RestIndex;
import org.neo4j.rest.graphdb.traversal.RestTraversalDescription;

import com.tr.cmg.alloy.aspects.audit.DaoTierAuditAspect;
import com.tr.cmg.alloy.dao.psd.relationship.RelationType;
import com.tr.cmg.alloy.dao.support.neo4j.Neo4jDaoSupport;
import com.tr.cmg.alloy.domain.psd.NodeType;
import com.tr.cmg.alloy.services.psd.rps.RelationalPathSearch;
import com.tr.cmg.alloy.services.psd.rps.RelationalPathSearchResult;

public class RelationalPathSearchDAO extends Neo4jDaoSupport{

public RelationalPathSearchResult executeRelationalPathSearch(
        RelationalPathSearch rps) {

    RestIndex<Node> personIndex = API.getIndex(NodeType.PERSON.name());

    Node start = personIndex.get("KEY", rps.getPerson1PermId()).getSingle();
    Node end = personIndex.get("KEY", rps.getPerson2PermId()).getSingle();

    Iterable<Node> nodes = null;
    Iterable<Relationship> relationships = null;

    if (start != null && end != null) {

        TraversalDescription td = createTraversalDescription(rps);
        nodes = null;
        relationships = null;
        for (Path position : td.traverse(start)) {

            // Log audit record info
            DaoTierAuditAspect
                    .storeSqlStatement("Relational Path Neo4j Query: "
                            + rps.getPerson1PermId() + " -> "
                            + rps.getPerson2PermId());
            DaoTierAuditAspect.storeSqlParameters("");

            System.out.println(position);

            if (position.endNode().equals(end)) {
                nodes = position.nodes();
                relationships = position.relationships();
                break;
            }
        }

        if(nodes == null) {
            ArrayList<Node> x = new ArrayList<Node>();
            x.add(start);
            x.add(end);
            nodes = x;
        }
    }

    return new RelationalPathSearchResult(nodes, relationships);

}

private TraversalDescription createTraversalDescription(RelationalPathSearch rps) {

    RestTraversalDescription rtd = (RestTraversalDescription) API.createTraversalDescription();
    rtd.maxDepth(4);

    return  rtd
            .depthFirst()
            .relationships(RelationType.IsDirector, Direction.BOTH)
            .relationships(RelationType.HasGraduatedFrom, Direction.BOTH)
            .relationships(RelationType.IsOfficer, Direction.BOTH)
            .relationships(RelationType.IsUnknownOfficerDirectorAt, Direction.BOTH)
            .relationships(RelationType.IsInsiderAt, Direction.BOTH)
            .relationships(RelationType.IsEquityAnalystAt, Direction.BOTH)
            .relationships(RelationType.IsMemberOrChairmanOf, Direction.BOTH)
            .relationships(RelationType.IsChiefInvestmentOfficerAt, Direction.BOTH)
            .relationships(RelationType.IsDirectorOfResearchAt, Direction.BOTH)
            .relationships(RelationType.IsPortfolioManagerAt, Direction.BOTH)
            .relationships(RelationType.IsTraderAt, Direction.BOTH)
            .relationships(RelationType.IsEconomistAt, Direction.BOTH)
            .relationships(RelationType.IsSalesProfessionalAt, Direction.BOTH)
            .relationships(RelationType.IsStrategistAt, Direction.BOTH)
            .relationships(RelationType.IsExecutiveOfficerAt, Direction.BOTH)
            .relationships(RelationType.IsShariahSupervisoryAt, Direction.BOTH)
            .relationships(RelationType.IsNonExecutiveAt, Direction.BOTH)
            .relationships(RelationType.IsVEExecutive, Direction.BOTH)
            .relationships(RelationType.IsProvidingResearchOn, Direction.BOTH)
            .relationships(RelationType.IsAnalystAt, Direction.BOTH)
            .relationships(RelationType.IsReuterMessengerUserAt, Direction.BOTH)
            .relationships(RelationType.IsProvidingAssetClassCoverageOn, Direction.BOTH)
            .relationships(RelationType.IsSpeakingLanguageOf, Direction.BOTH)
            .relationships(RelationType.IsProvidingGeographyCoverageOf, Direction.BOTH)
            .relationships(RelationType.IsUnknownSellSideBuySideAt, Direction.BOTH)
            .relationships(RelationType.IsUnknownInsiderAt, Direction.BOTH)
            .relationships(RelationType.IsUnknownResearchAnalystAt, Direction.BOTH)
            .relationships(RelationType.IsUnknownVEExecutiveAt, Direction.BOTH)
            .relationships(RelationType.IsUnknownReutersMessengerUserAt, Direction.BOTH)
            .relationships(RelationType.IsUnknownStreetEventsUserAt, Direction.BOTH);
}

public static void main(String[] args) {

    RelationalPathSearchDAO dao = new RelationalPathSearchDAO();

    RelationalPathSearch rps = new RelationalPathSearch();
    rps.setPerson1PermId("34414591164");
    rps.setPerson2PermId("34414710307");

    RelationalPathSearchResult result = dao.executeRelationalPathSearch(rps);
    result.toJSON();

}

}

4

4 に答える 4

1

JVMの最大ヒープメモリサイズを増やす必要があります。

現在のJVMメモリ設定は何ですか？

于 2013-01-08T20:00:16.873 に答える
0

それは解決され、採用されたアプローチはデータベース全体をjsonにプルし、ネットワークを介してデータベース内で実行する必要がある何かを実行します。

これは、このGitHubの問題で解決されています。

于 2013-01-09T14:35:11.540 に答える
0

2つのノード間のパスを見つけようとしているようですよね？代わりに、REST APIを介してallPathsまたはallSimplePathsアルゴリズムを使用する場合は、双方向トラバーサルになるため、より高速で必要なメモリが少なくなります。

ただし、RestGraphDatabaseがそれをサポートしているかどうかはわかりません。どちらの方法でも、 http：//docs.neo4j.org/chunked/stable/rest-api-graph-algos.htmlを見ることができます。

于 2013-01-09T14:33:18.167 に答える
0

「-XMX」パラメータを使用して、ヒープスペースのメモリを増やすことができます。これも参照できます... Javaのメモリ内のヒープスペースを増やす方法

于 2013-01-09T09:24:27.247 に答える