Mailing-List: contact issues-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@ignite.apache.org
Date: Tue, 7 Nov 2017 17:43:00 +0000 (UTC)
From: "Nikolay Izhikov (JIRA)" <jira@apache.org>
To: issues@ignite.apache.org
Message-ID: <JIRA.12780068.1425648544000.172089.1510076580823@Atlassian.JIRA>
In-Reply-To: <JIRA.12780068.1425648544000@Atlassian.JIRA>
References: <JIRA.12780068.1425648544000@Atlassian.JIRA> <JIRA.12780068.1425648544894@jira-lw-us.apache.org>
Subject: [jira] [Commented] (IGNITE-425) Introduce transformers for
 continuous queries
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Tue, 07 Nov 2017 17:43:05 -0000


    [ https://issues.apache.org/jira/browse/IGNITE-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242498#comment-16242498 ] 

Nikolay Izhikov commented on IGNITE-425:
----------------------------------------

Hello, [~avinogradov].

Did you have a chance to review the ticket?

> 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
>             Fix For: 2.4
>
>
> 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)