java - テキスト ファイルから読み取るときに Apache Ignite Cache をロードする方法

Question

ファイル helloworld.txt を作成しました。今、私はファイルから読み取っています。次に、ファイルの内容をキャッシュにロードしたいと考えています。キャッシュが更新されるたびに、ファイルにも書き込む必要があります。

これまでの私のコードは次のとおりです。

Apache Ignite のドキュメントでは説明が明確でないため、キャッシュをロードしてからキャッシュからファイルに書き込む方法を教えてください。

   import java.io.BufferedReader; 
import java.io.FileNotFoundException; 
import java.io.FileReader; 
import java.io.IOException; 

import org.apache.ignite.Ignite; 
import org.apache.ignite.IgniteCache; 
import org.apache.ignite.IgniteDataStreamer; 
import org.apache.ignite.IgniteException; 
import org.apache.ignite.Ignition; 
import org.apache.ignite.examples.ExampleNodeStartup; 
import org.apache.ignite.examples.ExamplesUtils; 

public class FileRead { 
    /** Cache name. */ 
    private static final String CACHE_NAME = "FileCache"; 


    /** Heap size required to run this example. */ 
    public static final int MIN_MEMORY = 512 * 1024 * 1024; 

    /** 
     * Executes example. 
     * 
     * @param args Command line arguments, none required. 
     * @throws IgniteException If example execution failed. 
     */ 
    public static void main(String[] args) throws IgniteException { 
        ExamplesUtils.checkMinMemory(MIN_MEMORY); 

        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) { 
            System.out.println(); 


            try (IgniteCache<Integer, String> cache = ignite.getOrCreateCache(CACHE_NAME)) { 
                long start = System.currentTimeMillis(); 

                try (IgniteDataStreamer<Integer, String> stmr = ignite.dataStreamer(CACHE_NAME)) { 
                    // Configure loader. 
                    stmr.perNodeBufferSize(1024); 
                    stmr.perNodeParallelOperations(8); 

                    ///FileReads(); 

                    try { 
                   BufferedReader in = new BufferedReader 
                   (new FileReader("/Users/akritibahal/Desktop/helloworld.txt")); 
                   String str; 
                   int i=0; 
                   while ((str = in.readLine()) != null) { 
                  System.out.println(str); 
                  stmr.addData(i,str); 
                  i++;  
                      } 
                   System.out.println("Loaded " + i + " keys."); 
                     } 
                   catch (IOException e) { 
                   } 


                } 


            } 
        } 
    } 

}