apache ignite data streamer

Question

Igniteのストリーミング部分について質問があります。

私が理解しているのは、キャッシュにデータをインポートする方法ですが、ストリーム受信者が他のカスタムロジックを適用するように設定できることもわかります。

私は受信者クラスとクラスを作成してストリームにデータを注入しようとしましたが（サーバーモードでは2つのメインインスタンスと2つのIgniteインスタンス）、 "ちょうど"ストリーマのキャッシュにデータがあります受信ロジックに処理されるカスタムロジックはありません）。だから、もし私が何かを見逃してしまったのか、それともStreamsがIgniteになったのかよく分からないのかと尋ねています。

送信者の部分を受信者に入れると、私は印刷物を持っています。

誰かが私がやっていること（または理解）が間違っていることを知っていますか？

レシーバクラス：

public class Receiver { 
    public static void main(String[] args){ 
     IgniteConfiguration igniteConfig = new IgniteConfiguration(); 
     CacheConfiguration<String, String> cacheConfig = new CacheConfiguration<>("CacheStream"); 


     igniteConfig.setCacheConfiguration(cacheConfig); 


     Ignite ignite = Ignition.getOrStart(igniteConfig); 

     IgniteDataStreamer<String, String> streamer = ignite.dataStreamer("CacheStream"); 

     streamer.receiver(StreamVisitor.from((cacheLambda, e) -> { 
      System.out.println("Value : " + e.getValue()); 
     })); 
    } 
} 

送信者クラス：

public class Sender { 
    public static void main(String[] args){ 
     IgniteConfiguration igniteConfig = new IgniteConfiguration(); 
     CacheConfiguration<String, String> cacheConfig = new CacheConfiguration<>("CacheStream"); 

     igniteConfig.setCacheConfiguration(cacheConfig); 

     Ignite ignite = Ignition.getOrStart(igniteConfig); 

     IgniteDataStreamer<String, String> streamer = ignite.dataStreamer("CacheStream"); 

     for(int i = 0 ; i < 10 ; i++){ 
      streamer.addData("key-"+i, "value-"+i); 
     } 
     streamer.flush(); 
    } 
} 

敬具

Answer 1

ignite.dataStreamer（ "CacheStream"）は、以前に作成したものと同じデータストリーマを返しません。毎回新しいデータストリームを作成します。

あなたのケースでは、2つの異なるデータストリームを設定し、受信機を設定していないストリーマーでデータをアップロードしました。