Cache.invoke are terribly slow and can't update cache

[Shawn Du]

Hi experts,

 

I try to update cache by delta by calling invoke. This is the code, it is
terribly slow and run out of Memory and no cache updated. Please help.

 

table.getRows().forEach(r -> cache.invoke(r.getKey(), (entry, args) ->

{

         BinaryObject bo = entry.getValue();

         if (bo == null)

         {

                   BinaryObjectBuilder builder =
IgniteManager.getIgnite().binary().builder(cacheName);

                   builder.setField("site", r.getSite());

                   ...

                   bo = builder.build();

         }

         BinaryObjectBuilder builder = bo.toBuilder();

         for (String measName : table.getSchema().getMeasNames())

         {

                   String measValue = r.getMeasValue(table.getSchema(),
measName);

                   if (measValue != null)

                   {

                            builder.setField(measName, measValue);

                   }

         }

         return null;

}));

 

 

Thanks

Shawn