GAS APIの実装と使用

Question

GAS APIを学習して使用して、データベース上のランダムウォークを実装し、訪問された各頂点を開始頂点に関連付けようとしています。

私はこれをどうやって管理できるか理解しているいくつかの問題があります。私は、PATHS、BFS、PR、および他のGASクラスを例としてレビューしてきましたが、私はどのように起動するかについてはあまりよく分かりません。

私の実装はBaseGASProgramに拡張し、必要なメソッドを実装する必要があります。また、繰り返しとして、フロンティアには現在の反復のすべての頂点が含まれます。前身のという概念はでもわかります。

しかし、私はGather、Apply、Scatterの哲学と、これらの3つの概念にランダムウォークを配布する方法をよく理解しているとは思いません。

また、コードを実装したら、どうすればいいですか？私のコードの中ですでに実装されているアルゴリズム（PR、SSSP、BFSなど）を呼び出すにはどうしたらいいですか？ SSSPオブジェクトをインスタンス化する必要がありますか？またはGASContext？ GASRunnerBase？

Answer 1

bigdataガスパッケージにTestBFSクラスを見てみましょう：

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] 

テストケースのコンテキストの外でそれを使用するには、いくつかの並べ替えのSailConnectionを作成する必要があります。例については、blazegraph-samples GitHubプロジェクトを参照してください。次にSAILGASEngineを作成する必要があります。これにより、GASEngineをJavaレイヤーに直接呼び出すという観点から始められます。