[ https://issues.apache.org/jira/browse/IGNITE-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16353812#comment-16353812 ]
Nikolay Izhikov commented on IGNITE-425: ---------------------------------------- Full benchmark results - https://gist.github.com/nizhikov/7e2260e17149779112918fe4713616d7 Final results - {noformat} # Run complete. Total time: 01:16:16 Benchmark Mode Cnt Score Error Units CQBenchmark.putBatch thrpt 5 0,449 ± 0,012 ops/s CQBenchmark.putBatch:listenerReceiveEvt thrpt 5 65672877,000 # CQBenchmark.putBatch:putCnt thrpt 5 65699963,000 # CQWTIdBenchmark.putBatch thrpt 5 0,463 ± 0,016 ops/s CQWTIdBenchmark.putBatch:listenerReceiveEvt thrpt 5 67976314,000 # CQWTIdBenchmark.putBatch:putCnt thrpt 5 67993769,000 # CQWTNullBenchmark.putBatch thrpt 5 0,468 ± 0,009 ops/s CQWTNullBenchmark.putBatch:listenerReceiveEvt thrpt 5 68450947,000 # CQWTNullBenchmark.putBatch:putCnt thrpt 5 68485270,000 # CQWTValueBenchmark.putBatch thrpt 5 0,400 ± 0,029 ops/s CQWTValueBenchmark.putBatch:listenerReceiveEvt thrpt 5 58452259,000 # CQWTValueBenchmark.putBatch:putCnt thrpt 5 58491036,000 # {noformat} > 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 > Affects Versions: 2.2 > Reporter: Yakov Zhdanov > Assignee: Nikolay Izhikov > Priority: Major > Fix For: 2.5 > > > 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 (v7.6.3#76005)