Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io 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 9126C1672AA for ; Wed, 9 Aug 2017 02:09:46 +0200 (CEST) Received: (qmail 89575 invoked by uid 500); 9 Aug 2017 00:09:45 -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 89563 invoked by uid 99); 9 Aug 2017 00:09:45 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 09 Aug 2017 00:09:45 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 28D70C01DB for ; Wed, 9 Aug 2017 00:09:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.38 X-Spam-Level: ** X-Spam-Status: No, score=2.38 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_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd4-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 (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id cRJPWTs954Le for ; Wed, 9 Aug 2017 00:09:44 +0000 (UTC) Received: from mail-vk0-f54.google.com (mail-vk0-f54.google.com [209.85.213.54]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 6CF795F6BF for ; Wed, 9 Aug 2017 00:09:43 +0000 (UTC) Received: by mail-vk0-f54.google.com with SMTP id u133so20115713vke.3 for ; Tue, 08 Aug 2017 17:09:43 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=vlNrDJ03nAYwrh4yxXpSmRNpymP77cmJJy6dDDsILpU=; b=oY8xZoc01Kj/Z85gqrPwSFbyhr5ArRPYNGVzlyWBAgkWjFv5yRSvSY1lv7CnNvD7U4 HVu6lxSCrW+l8invCGxoxBtEqgmuNC2Tmbj6PRZWs5N1dSjbQV0AMEb8RTK5EtnMH1ZA EoV0HlaGwn0VGHBBw9JXywQZjzwbKGefunhp2k+EMMEbM9rrb2xa2tWL1tdY29tCzD3a 0S35RT/CsHo4JJTXRYQcftXsV/uaiQ8I5NlsuCGQP3Bli+3RdP/8Gjd2YCQTuPOfpKiS VsnSmiFs2YCyiH+AetxOVqhqCC1K2s1ZfI9Du2Qtzcs3+g04F16g7H40CgIAP8um6k+e zFcA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=vlNrDJ03nAYwrh4yxXpSmRNpymP77cmJJy6dDDsILpU=; b=Bpuo5omS6a2TbYsXjpLj0xpUBbugVQoyrZoMCfo+r6SBJQ6QAZD3cxqFh2CJQE44Jy ngk3Q7y5g55sKglxcfY97IezNN4fHzRhs5JYsMEXuyl+UUVOzbvxnOCRyF40O/UMJj3N ewVdXdh77RgMLhehdir0y94hQ19CrblHDJhxW/iproWheqyfx5m9wTlK4B9GgB0ISGEM C/PSTRi7w/wGsdHz8DAdmVshfDF9/uiPuzTF2wcxHG79VsTN1MRkRwSGr5PExg7Ursu7 Kk0R7T4NpAWpfyUMQKU+YgunZ9qo2NUWJ3DpD0huIS9OKPq3FfK2bwCnvpKxBPrHZovB 1EfQ== X-Gm-Message-State: AHYfb5jqui0TDPasuVsXeiaKLmqe4H0KfGiBuEPJABk/anYWXVnjyb6M Mex6wYhAk6m/03Qw5sxypAv8rhgbn+eCphE= X-Received: by 10.31.69.8 with SMTP id s8mr4091673vka.102.1502237375539; Tue, 08 Aug 2017 17:09:35 -0700 (PDT) MIME-Version: 1.0 Received: by 10.103.55.65 with HTTP; Tue, 8 Aug 2017 17:09:34 -0700 (PDT) In-Reply-To: References: <1498102054850-14039.post@n6.nabble.com> <1498124667287-14041.post@n6.nabble.com> <1498679803059-14148.post@n6.nabble.com> <1498773580764-14168.post@n6.nabble.com> <1499285775268-14345.post@n6.nabble.com> <1500665879869-15263.post@n6.nabble.com> <1500939231924-15525.post@n6.nabble.com> <1501028214638-15646.post@n6.nabble.com> From: Jessie Lin Date: Tue, 8 Aug 2017 17:09:34 -0700 Message-ID: Subject: Re: Streaming test To: user@ignite.apache.org Content-Type: multipart/alternative; boundary="001a114daf8a232fe1055646e560" --001a114daf8a232fe1055646e560 Content-Type: text/plain; charset="UTF-8" Val, I replace atomicSequence with atomicLong and used the method below. I need to specify an initial value, start, according to requirement. return ignite.atomicLong( "id", // name. start, // Initial value true // Create if it does not exist. ); But the process got stuck as well. Shall I do something differently? Appreciate your advice. Best, Jessie On Tue, Jul 25, 2017 at 7:55 PM, Jessie Lin wrote: > Thank you Val. I'll give it a try. > > On Tue, Jul 25, 2017 at 5:16 PM, vkulichenko < > valentin.kulichenko@gmail.com> wrote: > >> Jessie, >> >> atomicLong() method will do this for you automatically. It either creates >> new instance or returns existing one. There is no need for separate >> initialization step. >> >> -Val >> >> >> >> -- >> View this message in context: http://apache-ignite-users.705 >> 18.x6.nabble.com/Streaming-test-tp14039p15646.html >> Sent from the Apache Ignite Users mailing list archive at Nabble.com. >> > > --001a114daf8a232fe1055646e560 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Val, I replace=C2=A0atomicSequence with atomicLong and use= d the method below.
I need to specify an initial value, start, accordin= g to requirement.
return ignite.atomicLong(
<=
/span>        "id"=
;, //  name.
        start,       // Initial value
        true     // Create=
 if it does not exist.
);
But the process got stuck as well.
Shall I do something differently? Appreciate your advice.

Best,
Jessie

On Tue, Jul 25, 2017 at 7:55 PM, Jessi= e Lin <jessie.jianwei.lin@gmail.com> wrote:
Thank you Val. I'll give = it a try.

On Tue, Jul 25, 2017 at 5:16 PM, vkul= ichenko <valentin.kulichenko@gmail.com> wro= te:
Jessie,

atomicLong() method will do this for you automatically. It either creates new instance or returns existing one. There is no need for separate
initialization step.

-Val



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Streaming-t= est-tp14039p15646.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com= .


--001a114daf8a232fe1055646e560--