ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ishan Jain <jain.isha...@gmail.com>
Subject Re: IGFS Question
Date Thu, 08 Jun 2017 03:21:04 GMT
But for this i have to open ignite with IGFS config. How will i use ignite
then with normal config?

On Wed, Jun 7, 2017 at 3:55 PM, Yermek <yermek.kumarbekov@gmail.com> wrote:

> 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.
>

Mime
View raw message