ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Valentin Kulichenko <valentin.kuliche...@gmail.com>
Subject Re: Batch size parameter at DataStreamerCacheUpdaters.batched()
Date Thu, 15 Feb 2018 20:49:59 GMT
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 <roman@gromtech.ru> wrote:

> Hello Igniters,
>
> In some cases, batched stream receiver can help us to improve performance:
>
> try (IgniteDataStreamer&lt;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/
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message