Re: IGFS Question

[Yermek]

Hi, maybe like this:

try (
         InputStream in = fs.open(new IgfsPath(dataPath));
         BufferedReader buffer = new BufferedReader(new
InputStreamReader(in));
         IgniteDataStreamer<Integer,String> dsStreamer =
ignite.dataStreamer(cache.getName())
     )
       {
            AtomicInteger i = new AtomicInteger();
            buffer.lines().forEach(s ->
dsStreamer.add(i.getAndIncrement(),s));
        }
                




--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/IGFS-Question-tp13447p13463.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.