ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Roman Guseinov <ro...@gromtech.ru>
Subject Batch size parameter at DataStreamerCacheUpdaters.batched()
Date Thu, 15 Feb 2018 13:52:12 GMT
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
View raw message