[
https://issues.apache.org/jira/browse/IGNITE-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345352#comment-16345352
]
Anton Vinogradov edited comment on IGNITE-425 at 1/30/18 4:53 PM:
------------------------------------------------------------------
[~NIzhikov],
Bench should be refactored
1) We should wait for event. We interested in time between put and event
2) We should have iteration longer than 10 seconds. Warmup should be longer too.
3) We should perform puts from 16 -> 64 threads, depends of you CPU cores.
Results looks unrealistic since in CQWT mode you're send more than in CQ mode
was (Author: avinogradov):
[~NIzhikov],
Bench should be refactored
1) We should wait for event. We interested in time between put and event
2) We should have iteration longer than 10 seconds. Warmup should be longer too.
3) We should perform puts from 16 -> 64 threads, depends of you CPU cores.
> 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)
