unsubscribe

Re: Effective Data through DataStream

Hi, i need a receiver because i want to increase the value of item if it is stored in cache, like a word-count example. I agree with you about flush. Thanks, Mimmo Il dom 22 apr 2018, 08:57 begineer ha scritto: > I dont understand why you need to define receiver to update

Re: Ignite Information

Hi Val, Thanks for reply. We are trying to eliminate the reduce step in hadoop processing by sending each map results in a distribuited cache for minimize time of execution. Do you think it's a reasonable thing? When we send data with DataStream overwrite true through more parallel DataStreamer

Re: Ignite DataStream Troughput

Hi Mikhail, Thanks for reply. I tried with set overwrite false, throughput is inscreased and time has decreased. 3 parallel DataStream 26s on 1 Server Node. We need to update the entries if we set overwrite false, so how can we do ? We need a sort of reduce job on Ignite Server, is there any

Re: Ignite Information

Hi thanks for the reply. We can't filter data. public class NodeFilter implements IgnitePredicate { private static final long serialVersionUID = 0L; public NodeFilter() { System.out.println("Start NodeFilter"); } @Override public boolean apply(ClusterNode node) {

Re: Ignite Information

Thank you, Sorry but I can not understand how to implement it. Could you please show me an example of its use? I just started to use Ignite. Thanks 2017-07-07 0:03 GMT+02:00 vkulichenko : > Hi, > > See CacheConfiguration#nodeFilter property. It's just a predicate

Re: Performance WordCount to Hadoop

Hi, Thanks for your reply. We are testing ignite performances on hadoop without hadoop-accelerator for eventually use it in our project. We have a file of 700mb wich is spitted in 6 map tasks, I think that setup time it's not expensive, it's 6-7 seconds. The cache.put which you have mentioned is

Re: Hadoop and Ignite, Problem grid cache

spi.setIpFinder(ipFinder); > > IgniteConfiguration cfg = new IgniteConfiguration(); > > cfg.setDiscoverySpi(spi); > > cfg2.setName("demoCache"); > cfg2.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL); > > ignite =

Re: Hadoop and Ignite, Problem grid cache

Hi, Thanks for reply. There's a problem with cache creation i resolved starting cache from one of the server node. Now I have another problem, when i run hadoop with there jar file all work, but when i try to put a word in a cache it doesn't put it... I think there's a problem when try to find