[jira] [Comment Edited] (IGNITE-425) Introduce transformers for continuous queries

["Nikolay Izhikov (JIRA)" <ji...@apache.org>]

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

Nikolay Izhikov edited comment on IGNITE-425 at 9/4/17 12:57 PM:
-----------------------------------------------------------------

Hello, [~ntikhonov] 

I discuss changes with community

http://apache-ignite-developers.2346864.n4.nabble.com/ContinuousQueryWithTransformer-implementation-questions-2-td21418.html#a21673

Decisions:

# Introduce base class for ContinuousQuery to prevent code duplication - \[DONE\]
# Keep current implementation of exception handling
## filter exception treats as `true`
## transformer exception treats as `null`
# Start another dev-list discussion to make exception handling clear both in regular ContinuousQuery and in ContinuousQueryWithTransformer.

Can you continue reviewing my PR?
Should I merge my PR with latest master?


was (Author: nizhikov):
Hello, [~ntikhonov] 

I discuss changes with community

http://apache-ignite-developers.2346864.n4.nabble.com/ContinuousQueryWithTransformer-implementation-questions-2-td21418.html#a21673

Decisions:

# Introduce base class for ContinuousQuery to prevent code duplication - \[DONE\]
# Keep current implementation of exception handling
## filter exception treats as `true`
## transformer exception treats as `null`
# Start another dev-list discussion to make exception handling clear both in regular ContinuousQuery and in ContinuousQueryWithTransformer.

Can you continue reviewing my PR?
Should I merge my PR with lates master?

> 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)