You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/08/01 15:40:01 UTC
[jira] [Commented] (IGNITE-425) Introduce transformers for
continuous queries
[ https://issues.apache.org/jira/browse/IGNITE-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16109112#comment-16109112 ]
ASF GitHub Bot commented on IGNITE-425:
---------------------------------------
GitHub user nizhikov opened a pull request:
https://github.com/apache/ignite/pull/2372
IGNITE-425: Implementation of ContinuousQueryWithTransformer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nizhikov/ignite IGNITE-425
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/ignite/pull/2372.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2372
----
commit a188dfa481796fe554085a9c729e327740d6242e
Author: Nikolay Izhikov <ni...@gmail.com>
Date: 2017-08-01T15:37:49Z
IGNITE-425: Implementation of ContinuousQueryWithTransformer
----
> 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)