Batch size parameter at DataStreamerCacheUpdaters.batched()

[Roman Guseinov]

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/