Re: Map Reduce over cache items, where values are sequences

2019-10-01 Thread Evgenii Zhuravlev
For example, query with partition will look like : QueryCursor> qry = cache.query(new ScanQuery().setPartition(part)); вт, 1 окт. 2019 г. в 15:25, Evgenii Zhuravlev : > Hi, > > To parallelise everything properly, I would recommend starting an > affinityCallable per partition(1024 by

Re: Map Reduce over cache items, where values are sequences

2019-10-01 Thread Evgenii Zhuravlev
Hi, To parallelise everything properly, I would recommend starting an affinityCallable per partition(1024 by default). Inside this compute job, you can collect information for the certain partition only using ScanQuery(or SQLQuery) пт, 27 сент. 2019 г. в 18:09, Stas Girkin : > Hello everyone,

Map Reduce over cache items, where values are sequences

2019-09-27 Thread Stas Girkin
Hello everyone, I would like to use MapReduce over cache items representing events happened in a process to calculate certain statistics. Could you be so kind to help me how can I do that with apache ignite? I have tens of millions of processes that happened in the past. The processes look like