[ https://issues.apache.org/jira/browse/IGNITE-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124251#comment-16124251 ]
Nikolay Izhikov commented on IGNITE-425: ---------------------------------------- TC - https://ci.ignite.apache.org/project.html?projectId=Ignite20Tests&branch_Ignite20Tests=pull%2F2372%2Fhead [~ntikho...@apache.org] Can you please review my changes? > Introduce transformers for continuous queries > --------------------------------------------- > > Key: IGNITE-425 > URL: https://issues.apache.org/jira/browse/IGNITE-425 > Project: Ignite > Issue Type: Sub-task > Components: cache > Reporter: Yakov Zhdanov > Assignee: Nikolay Izhikov > > Currently if updated entry passes the filter, it is sent to node initiated > the query entirely. It would be good to provide user with the ability to > transform entry and, for example, select only fields that are important. This > may bring huge economy to traffic and lower GC pressure as well. > Possible signatures will be: > {noformat} > public final class ContinuousQuery<K, V, T> {..} // T is a type transformer > transforms to > public ContinuousQuery<K, V, T> setLocalListener(Listener<T> locLsnr) {..} // > Probably, we will have to introduce new listener type, since user may want to > wipe out key as well. > /* new method to add */ > public ContinuousQuery<K, V, T> setRemoteTransformerFactory(Factory<? extends > ContinuousQueryTransformer<K, V, T>> factory) { ..} > {noformat} -- This message was sent by Atlassian JIRA (v6.4.14#64029)