From user-zh-return-339-archive-asf-public=cust-asf.ponee.io@flink.apache.org Tue Apr 16 12:44:39 2019 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 [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 491AC180630 for ; Tue, 16 Apr 2019 14:44:39 +0200 (CEST) Received: (qmail 60059 invoked by uid 500); 16 Apr 2019 12:44:38 -0000 Mailing-List: contact user-zh-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user-zh@flink.apache.org Delivered-To: mailing list user-zh@flink.apache.org Received: (qmail 60042 invoked by uid 99); 16 Apr 2019 12:44:37 -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; Tue, 16 Apr 2019 12:44:37 +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 509FAC2926 for ; Tue, 16 Apr 2019 12:44:37 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.001 X-Spam-Level: X-Spam-Status: No, score=-0.001 tagged_above=-999 required=6.31 tests=[DKIMWL_WL_MED=-0.001, DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, 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=silvrr-com.20150623.gappssmtp.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 gEgPAIP9-Y36 for ; Tue, 16 Apr 2019 12:44:35 +0000 (UTC) Received: from mail-pf1-f181.google.com (mail-pf1-f181.google.com [209.85.210.181]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 6955E5F3EF for ; Tue, 16 Apr 2019 12:44:35 +0000 (UTC) Received: by mail-pf1-f181.google.com with SMTP id c207so10365236pfc.7 for ; Tue, 16 Apr 2019 05:44:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=silvrr-com.20150623.gappssmtp.com; s=20150623; h=from:content-transfer-encoding:mime-version:subject:date:references :to:in-reply-to:message-id; bh=rhixfsApoJQWHJDCL3acLXs273LMw3czA1lpRmlwSrc=; b=abevWSsVadPmx+M3AKICUc24/dZ+uNK+34fZdNaLxQaSjtqMa4ymR9qZfN9UYA7yFM +bYGSZKJloIIGhVC5Pp73YMhLan9ro6nVjpmEIGmVD+EwosueLgZyZFmwfRc/BMD3V4I 4Vo+dD5BH9dgAycb8FziiG3nJ5CYYM7oFC2HWN1a/Pam6AkFbcA3yHmLSWkC7chZgASd /1AATzBcNngal7SoJc4bjSNq6H1/P1oIuOFHQ8yp7JdJcCuUFELT4r+4T47+7WIQsy+k TAoIWaDfg9XLsnSy0UMy0KudaLdLUzZMl3Ndg23rzACScHgTfTwXUWlgvfBcoUwHfyxs pUzw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version :subject:date:references:to:in-reply-to:message-id; bh=rhixfsApoJQWHJDCL3acLXs273LMw3czA1lpRmlwSrc=; b=KaZkzEDEkfAh+SXWiHPIMo8AmBbVOXAzdoxsiVi50dXCoRxm7b3qXRvPxrecSrYZZ9 9CdNAjvszb0ldMJmD8D4Sh8A4khCrS+K/m73IgGgC6uOFBoAE5Z3FdPD4HFgck7TL8NK 4VAjLc5Uhxiqqo/KFHvhK+gIyLF0AXSKfaSpMHcaa8nUcsvSPxrCceSXvgf/jSD+C5LI 6GrdyjzYaa9yFxC8fFvslqWwuz9t1gvtXjjxy8zcN3hQvnw38D4Vm0i2y6/YH+rUFo9q RUrJ6conVzK4cx//9E0zaxveLkWqUTHbIaEGSpz4GGAwzw7je1mD6aBbZBfCC0YNqctD SqwQ== X-Gm-Message-State: APjAAAV5Yb0AxOr5XUWlFO1U88zkdhAVADV5KtNrKEzQj6jVhxwiEmyl qYB1aRSd04NSLo9Nb7eFVSPmnL7MBEA= X-Google-Smtp-Source: APXvYqwdQHmi30mJZCAqyypKJoBiZgdZJVF0szYo5wZMPZ7lKquQqSWaMpe9uS6qpgAkZGJnkXn1ZA== X-Received: by 2002:a63:3190:: with SMTP id x138mr73932592pgx.273.1555418673595; Tue, 16 Apr 2019 05:44:33 -0700 (PDT) Received: from [10.0.19.65] ([164.52.75.136]) by smtp.gmail.com with ESMTPSA id 129sm54159338pgc.24.2019.04.16.05.44.31 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Tue, 16 Apr 2019 05:44:32 -0700 (PDT) From: zhang yue Content-Type: text/plain; charset=gb2312 Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Mac OS X Mail 11.5 \(3445.9.1\)) Subject: =?gb2312?B?UmU6IEZsaW5rINe0zKzKudPDzsrM4tfJ0a8=?= Date: Tue, 16 Apr 2019 20:44:26 +0800 References: <14919390-3eb1-4daa-aff7-45e54ccc8d90@Spark> To: user-zh@flink.apache.org In-Reply-To: <14919390-3eb1-4daa-aff7-45e54ccc8d90@Spark> Message-Id: <32E05896-5DF6-4BCF-91BF-6D150FC35F8A@silvrr.com> X-Mailer: Apple Mail (2.3445.9.1) Savepoint Reader/Writer = =CA=D7=CF=C8=BD=AB=CD=E2=B2=BF=CA=FD=BE=DD=D0=B4=C8=EBsavepoint=A3=AC=C8=BB= =BA=F3=B4=D3savepoint=C6=F4=B6=AF=C2=F0 > =D4=DA 2019=C4=EA4=D4=C216=C8=D5=A3=AC=CF=C2=CE=E78:33=A3=ACCongxian = Qiu =D0=B4=B5=C0=A3=BA >=20 > Hi > = =C8=E7=B9=FB=C4=E3=CF=A3=CD=FB=B3=CC=D0=F2=D4=DA=B8=D5=BF=AA=CA=BC=D4=CB=D0= =D0=B5=C4=CA=B1=BA=F2=B4=D3=CD=E2=B2=BF=B4=E6=B4=A2=BC=D3=D4=D8=CA=FD=BE=DD= =A3=AC=D5=E2=B8=F6=D4=DD=CA=B1=D7=F6=B2=BB=B5=BD=A3=AC=B2=BB=B9=FD=CF=D6=D4= =DA=C9=E7=C7=F8=D5=FD=D4=DA=D7=F6 Savepoint Reader/Writer = =CF=E0=B9=D8=B5=C4=CA=C2=C7=E9=A3=AC=B5=BD=CA=B1=BA=F2=BE=CD=BF=C9=D2=D4=C1= =CB >=20 > Best, Congxian > On Apr 16, 2019, 20:27 +0800, zhang yue , wrote: >> =C4=E3=BA=C3=A3=AC=CE=D2=D3=D0=D2=BB=B8=F6keyed = state=A3=AC=B5=B1=CE=D2=C6=F4=B6=AFflink=B3=CC=D0=F2=CA=B1=A3=AC=CE=D2=D0=E8= =D2=AA=B8=F9=BE=DD=CA=FD=BE=DD=BF=E2=D6=D0=B5=C4=CA=FD=BE=DD=B8=F8=C3=BF=B8= =F6key=BC=D3=D4=D8=B2=BB=CD=AC=B5=C4=CA=FD=D6=B5=D7=B4=CC=AC=A3=AC=CE=D2=D3= =A6=B8=C3=D4=F5=D1=F9=C0=B4=B2=D9=D7=F7=C4=D8=A3=AC=D4=DA=CE=C4=B5=B5=C9=CF= =D5=D2=B2=BB=B5=BD=C0=FD=D7=D3=A3=AC=CE=D2=BE=F5=B5=C3=D3=A6=B8=C3=CA=C7=D4= =DAopen=BA=AF=CA=FD=D6=D0=C9=E8=D6=C3=B3=F5=CA=BC=D7=B4=CC=AC=A3=AC=B5=AB=CA= =C7=D4=DA=D5=E2=C0=EF=BB=F1=C8=A1=B2=BB=B5=BDkey=A1=A3 >>=20 >>=20 >> class LineItemStat extends RichFlatMapFunction { >>=20 >> /** >> * The ValueState handle. The first field is the count, the second = field a running sum. >> */ >> private transient MapState stat_value; >>=20 >> @Override >> public void flatMap(ObjectNode input, Collector out) = throws Exception { >>=20 >> // access the state value >>=20 >> } >>=20 >> @Override >> public void open(Configuration config) { >> MapStateDescriptor descriptor =3D >> new MapStateDescriptor( >> "stat_value",String.class, Long.class); // default value of the = state, if nothing was set >> stat_value =3D getRuntimeContext().getMapState(descriptor); >> } >> } >>=20