Ignite putとDataStreaming

Question

私はIgniteRunnableの大量を持ち、IgniteComputeで実行します。次のように彼らは見て次のようにそれを使用しようとして

public class MyIgniteRunnable implements IgniteRunnable{ 

    private Sting value; 
    private String key; 

    public MyIgniteRunnable(String key, String value){ 
     this.key = key; 
     this.value = value; 
    } 

    public void run{ 

     IgniteCache<String, String> cache = Ignition.localIgnite().getOrCreateCache("cache"); 
     String previous = cache.get(key); 
     String result; 
     //process previous and value 
     cache.put(key, result); //<------ Here 

    } 

} 

イム：

Ignite ignite; 
String key; 
String value; 
//... 
IgniteCompute compute = ignite.compute(); 
compute.affinityRun("cache", key, new MyIgniteRunnable(key, value)); 

しかし、イムタスクにputを使用して行うには正しいことであるかどうかわかりません。私はkeyでaffinityRunを使用しているので、各タスクは "正しい"ノードで実行されるので、putは大丈夫だと思っていました。

このアプローチは正しいですか、これを行うにはもっと効率的な方法がありますか？

キャッシュに入れる各タスクに要素が1つしかないので、ストリーミングを使用しませんでした。

Answer 1

キャッシュされた値に基づいてロジックを実行する必要がある場合は、正しい方法で、おそらく最も簡単です。ロジックを実行する最善の方法は、キーを格納するノード上です。 affinityRun（...）を使用しているため、キャッシュのput操作はローカルになり、冗長なネットワークトラフィックは発生しません。

一方、パフォーマンスを向上させるはずのDataStreamerも使用できますが、サーバー側でいくつかのコロケートされたロジックを実行する必要がある場合はもう少し複雑です。ここに記載されているStreamReciever、StreamTransformer、およびStreamVisitorをご覧ください。https://apacheignite.readme.io/docs/data-streamers