Re: What's the difference between EntryProcessor and distributed closure?

Hi Tracyl, You can use "invoke", the method will be most effective for retrieve part of value from cache. For the withKeepBinary off_heap cache "invoke" takes lock on entry and can to manipulate with off_heap pointer wrapped on BinaryObject. -- View this message in context: http://apache-ignit

Re: What's the difference between EntryProcessor and distributed closure?

Thanks Alexey. By predicate/projection pushdown, I mean: currently I am storing a native Spark Row object as value format of IgniteCache. If I retrieve it as an IgniteRDD, I only want certain column of that Row object rather than returning entire Row and do filter/projection at Spark level. Do you

Re: What's the difference between EntryProcessor and distributed closure?

Hi Tracyl, Can you describe in greater detail what you are trying to achieve? To my knowledge, predicate pushdown is a term usually used for map-reduce jobs. The concept of Ignite's jobs and tasks is more similar to fork-join rather than map-reduce semantics, so we could better help you if you des

What's the difference between EntryProcessor and distributed closure?

What I would like to do is to achieve predicate/column project push-down to the ignite cache layer. I guess this two options could do it, isn't it? If so, what's the difference? Are there any other options to achieve predicate push-down? Thanks in advance! -- View this message in context: http: