GAS-API Implementierung und Verwendung

Question

Ich versuche zu lernen und die GAS-API zu verwenden, um einen Random Walk über meine Datenbank zu implementieren, jeden besuchten Scheitelpunkt mit dem Startscheitelpunkt zu verknüpfen.

Ich habe einige Probleme zu verstehen, wie ich es schaffen kann; Ich habe die PFADE-, BFS-, PR- und andere GAS-Klassen als Beispiele besprochen, aber ich bin mir nicht sicher, wie ich anfangen soll.

Ich denke, dass meine Implementierung BaseGASProgram erweitern und die erforderlichen Methoden implementieren sollte. Auch iterativ enthält die Grenze alle Scheitelpunkte der aktuellen Iteration. Das Konzept Vorgänger ist mir auch klar.

Aber ich glaube nicht, dass ich sehr gut die Gather, Apply, Scatter Philosophie verstehe und wie man den Random Walk über diese drei Konzepte verteilt.

Auch, sobald ich meinen Code implementieren, wie nenne ich es? Wie rufe ich die bereits implementierten Algorithmen (PR, SSSP, BFS, etc.) in meinem Code auf? Sollte ich ein SSSP Objekt instanziieren und was dann? Oder GASContext? GASRunnerBase?

Answer 1

am TestBFS Klasse Werfen Sie einen Blick in das bigdata-Gas-Paket:

final IGASEngine gasEngine = getGraphFixture() 
     .newGASEngine(1/* nthreads */); 

try { 

    final SailConnection cxn = getGraphFixture().getSail() 
      .getConnection(); 

    try { 

     final IGraphAccessor graphAccessor = getGraphFixture() 
       .newGraphAccessor(cxn); 

     final IGASContext<BFS.VS, BFS.ES, Void> gasContext = gasEngine 
       .newGASContext(graphAccessor, new BFS()); 

     final IGASState<BFS.VS, BFS.ES, Void> gasState = gasContext 
       .getGASState(); 

     // Initialize the froniter. 
     gasState.setFrontier(gasContext, p.getMike()); 

     // Converge. 
     gasContext.call(); 

[snip] 

, es zu benutzen außerhalb des Testfalls Kontext, benötigen Sie einen SailConnection irgendeiner Art zu erstellen. Beispiele finden Sie in den blazegraph-samples GitHub-Projekt. Dann müssen Sie eine SAILGASEngine erstellen. Dies sollte Sie in Bezug auf den Aufruf der GASEngine direkt auf der Java-Ebene starten.