Roman,
DataStreamerCacheUpdaters class is actually not a part of public API, so I
don't see a reason to change it unless there is a need for this internally
in Ignite.
-Val
On Thu, Feb 15, 2018 at 5:52 AM, Roman Guseinov <ro...@gromtech.ru> wrote:
> Hello Igniters,
>
> In some cases, batched stream receiver can help us to improve performance:
>
> try (IgniteDataStreamer<Integer, String> streamer =
> ignite.dataStreamer(cacheName)) {
> streamer.receiver(DataStreamerCacheUpdaters.batched());
>
> streamer.addData(getData());
> }
>
> Unfortunately, the bad thing is that the receiver internally calls "putAll"
> for all data. I think it would be useful to have an option to specify a
> batch size like:
>
> DataStreamerCacheUpdaters.batched(256)
>
> What do you think about this? Is it make sense to create a ticket?
>
> Thanks.
>
> Best Regards,
> Roman
>
>
>
> --
> Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/
>
