2016-08-12 3 views
0

私たちのコードベースをgridgainからigniteに移植する際には、ほとんどのigniteメソッドに似た/名前を変更したメソッドがあります。私は明確にする必要があるいくつかあります。gridgainからigniteへの移植 - これらのgridgainメソッドの等価な点

  1. コンピューティングの未来を呼び出すための推奨方法は何

    //Listener for asynchronous local node grid events. You can subscribe for local node grid event notifications via {@link GridEventStorageManager#addLocalEventListener 
        public interface GridLocalEventListener extends EventListener {} 
    
  2. 用のIgnite同等とは何ですか。コンパイル失敗の画像を参照してください。

それとは別に、それはfuture.listenAsync(ように見える)(future.listenする必要があります)

 final ProcessingTaskAdapter taskAdapter = new ProcessingTaskAdapter(task, manager, node); 
     ComputeTaskFuture<ProcessingJob> future = grid.cluster() 
       .forPredicate(this) //===> what should this be 
       .compute().execute(taskAdapter, job); 
     future.listen(new IgniteInClosure<IgniteFuture<ProcessingJob>>() { 
      @Override 
      public void apply(IgniteFuture<ProcessingJob> future) { 
       try { 
        // Need this to extract the remote exception, if one occurred 
        future.get(); 
       } catch (IgniteException e) { 
        manager.fail(e.getCause() != null ? e.getCause() : e); 
       } finally { 
        manager.finishJob(job); 
        jobDistributor.distribute(taskAdapter.getSelectedNode()); 
       } 
      } 

GridGain vs Ignite

答えて

1
  1. 特別なクラスには、単に、もはやありませんリスナーとしてIgnitePredicateを使用してください。詳細は、[1]を参照してください。

  2. 非同期サポートの詳細については、[2]を参照してください。また、投影はクラスタグループ[3]に置き換えられました(そのため、あなたのコンパイルエラーの1つが原因です)。そして、あなたは正しい、listenAsynclistenに改名されました。

[1] https://apacheignite.readme.io/docs/events

[2] https://apacheignite.readme.io/docs/async-support

[3] https://apacheignite.readme.io/docs/cluster-groups

+0

再2.あなたはこのような何か意味ですか: をhttps://gist.github.com /匿名/ 074aa436a39f85e23f25e871894fc59f –

+1

はい、いいですね。 –

+0

私は投稿した要点スニペットの一部を忘れてしまった。どのように私たちの処理ジョブの1つを提出し、まだ未来を得るか。 古いコードでは、これを行いました ComputeTaskFuture future = grid.cluster() .forPredicate(this) .compute()。execute(taskAdapter、job); 新しいコードでは、私は次のことを実行できましたが、executeは処理ジョブインスタンス(クラスの1つ)を返すため、未来はexecuteに関連付けられていません ProcessingJob j = asyncCompute.execute(taskAdapter、job); –

関連する問題