Uploaded image for project: 'Ignite'
  1. Ignite
  2. IGNITE-1191 Continuous Query Changes
  3. IGNITE-425

Introduce transformers for continuous queries

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.2
    • Fix Version/s: 2.5
    • Component/s: cache
    • Labels:
      None

      Description

      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:

      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) { ..}
      
      

        Attachments

          Activity

            People

            • Assignee:
              nizhikov Nikolay Izhikov
              Reporter:
              yzhdanov Yakov Zhdanov
            • Votes:
              1 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: