Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id D28CC2009F8 for ; Fri, 3 Jun 2016 18:36:47 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id D12D0160A49; Fri, 3 Jun 2016 16:36:47 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 22F4E160A3B for ; Fri, 3 Jun 2016 18:36:46 +0200 (CEST) Received: (qmail 62252 invoked by uid 500); 3 Jun 2016 16:36:40 -0000 Mailing-List: contact user-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@ignite.apache.org Delivered-To: mailing list user@ignite.apache.org Received: (qmail 62175 invoked by uid 99); 3 Jun 2016 16:36:40 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Jun 2016 16:36:40 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 9E98B180510 for ; Fri, 3 Jun 2016 16:36:39 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.198 X-Spam-Level: * X-Spam-Status: No, score=1.198 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 1l8aKJyG-nvX for ; Fri, 3 Jun 2016 16:36:35 +0000 (UTC) Received: from mail-vk0-f44.google.com (mail-vk0-f44.google.com [209.85.213.44]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 5814E5F3A0 for ; Fri, 3 Jun 2016 16:36:34 +0000 (UTC) Received: by mail-vk0-f44.google.com with SMTP id c189so121955466vkb.1 for ; Fri, 03 Jun 2016 09:36:34 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=6h/sW+WXJBf6mhS/zcXvCo8q42o6OVw0I4J2h5j1fZk=; b=lvlGYHklKR+XfjECpUPi9Mk9t9bY+03iYFtlk0ZhiZwj5d1r/ee4uIyhEC3DSyJjN8 Vw5ltgF9A75ZF70IKxHuKCcSYG/aoBLmLwkqT6e7qruCi6AAwTg34bUY/whAwup6FWNf MX+v2WUKevnbV9WygjodnlQ6LHiRnT7vHinKMWWSSmFLShzYkxCAc2p/0B3gYNIlmO8/ D4qgLRMgnXn81T3tsDXyQ0BMGyLVwpCqpuTSED69Z0YA+KX7LerBAvM6JhSKeLZeS8GB 8Kcmh668uzkZpiaPBSwctcKF5FC2DLQUcSEp0TduxDdKFxnEzK53uOJmfQoYHlo1lMWK 3Wyw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=6h/sW+WXJBf6mhS/zcXvCo8q42o6OVw0I4J2h5j1fZk=; b=SWV5JpfsWX9vdRdHSqFJ93wu3G2J/EbT4tYg5jC+9WMmfoTZPVlT0ZF52mUqTI0Udl TJ8oH3bPY5/PVq//1nzbPH9Du7ibL0nArCTRDFyeNWir5aBZ9ZzBP6YRnx/tmSH6T0QK cxH6a71z3tx0JThkRzSqbflIvlh+aeMMIurd6nhmJk12mMKl/M0IsnRlxrl63cCcS6GQ 5K/7nLnah6jbU0skaB+SdeqlXxUtwc3MdnrSZT2YCUAEx/BuCrNlPgIzCJAjnzNyoLTD Cnt2HAhVxeKNSHgkOm5PcZo5/Kark5Fqvp/0kg/cVjRxzgvpZVP0Cp1+HRLo48EFkh8N l7Dw== X-Gm-Message-State: ALyK8tKxjTa/1G3ravf28hsiLGkOPs8aFLpapv0fWdMuItLolM9u9VIdNE3exU6FVbeIRJWRlIkqC/vIV5pf/Q== X-Received: by 10.31.11.137 with SMTP id 131mr1621138vkl.111.1464971793346; Fri, 03 Jun 2016 09:36:33 -0700 (PDT) MIME-Version: 1.0 Received: by 10.176.67.33 with HTTP; Fri, 3 Jun 2016 09:36:32 -0700 (PDT) In-Reply-To: <1712435395.669561.1464956586077.JavaMail.yahoo@mail.yahoo.com> References: <1712435395.669561.1464956586077.JavaMail.yahoo.ref@mail.yahoo.com> <1712435395.669561.1464956586077.JavaMail.yahoo@mail.yahoo.com> From: Alexey Goncharuk Date: Fri, 3 Jun 2016 09:36:32 -0700 Message-ID: Subject: Re: Ignite - Question about update counter field for continuous queries To: user@ignite.apache.org, M Singh Content-Type: multipart/alternative; boundary=001a1145a35a5937e10534625313 archived-at: Fri, 03 Jun 2016 16:36:48 -0000 --001a1145a35a5937e10534625313 Content-Type: text/plain; charset=UTF-8 Hi, Ignite client automatically checks the partition counter and filters out duplicate events, you do not need to do it manually to get rid of duplicates. However, starting from Ignite 1.6 update counter is available through CacheQueryEvent API. 2016-06-03 5:23 GMT-07:00 M Singh : > Hi Folks: > > I have a question about once only event delivery for continuous queries. > > The document (https://apacheignite.readme.io/docs/continuous-queries) > indicates that there is a per partition update counter which is sent to the > client along with the change notification. I checked the CacheEntryEvent > and could not find the update counter field. Also, is this field (update > counter) handled internally by Ignite client library (dropping duplicate > events on the client side) or does the client listener has to check it in > case of duplicate events. If the client listener has to check the update > counter, please let me know how to access this field. > > Thanks > > Mans > --001a1145a35a5937e10534625313 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

Ignite client automatically checks = the partition counter and filters out duplicate events, you do not need to = do it manually to get rid of duplicates. However, starting from Ignite 1.6 = update counter is available through CacheQueryEvent API.

2016-06-03 5:23 GMT-07:0= 0 M Singh <mans2singh@yahoo.com>:
Hi Folks:

I have a que= stion about once only event delivery for continuous queries. =C2=A0

The document (https://a= pacheignite.readme.io/docs/continuous-queries) indicates that there is = a per partition update counter which is sent to the client along with the c= hange notification.=C2=A0 I checked the CacheEntryEvent and could not find = the update counter field.=C2=A0 Also, is this field (update counter) handle= d internally by Ignite client library (dropping duplicate events on the cli= ent side) or does the client listener has to check it in case of duplicate = events.=C2=A0 If the client listener has to check the update counter, pleas= e let me know how to access this field.

Thanks

Mans

--001a1145a35a5937e10534625313--