Cool Here is my question:
Do we have insert, update and remove operations on Apache Flink? For example: I have 10 million records in my test file. I want to add one record, update one record and remove one record from this test file. How to implement it by Flink? Thanks. On Thu, Jun 4, 2015 at 10:44 AM, Robert Metzger <[email protected]> wrote: > Yes, I've got this message. > > On Thu, Jun 4, 2015 at 7:42 PM, Hawin Jiang <[email protected]> wrote: > >> Hi Admin >> >> Please let me know if you are received my email or not. >> Thanks. >> >> >> >> Best regards >> Hawin Jiang >> >> On Thu, Jun 4, 2015 at 10:26 AM, <[email protected]> wrote: >> >>> Hi! This is the ezmlm program. I'm managing the >>> [email protected] mailing list. >>> >>> Acknowledgment: I have added the address >>> >>> [email protected] >>> >>> to the user mailing list. >>> >>> Welcome to [email protected]! >>> >>> Please save this message so that you know the address you are >>> subscribed under, in case you later want to unsubscribe or change your >>> subscription address. >>> >>> >>> --- Administrative commands for the user list --- >>> >>> I can handle administrative requests automatically. Please >>> do not send them to the list address! Instead, send >>> your message to the correct command address: >>> >>> To subscribe to the list, send a message to: >>> <[email protected]> >>> >>> To remove your address from the list, send a message to: >>> <[email protected]> >>> >>> Send mail to the following for info and FAQ for this list: >>> <[email protected]> >>> <[email protected]> >>> >>> Similar addresses exist for the digest list: >>> <[email protected]> >>> <[email protected]> >>> >>> To get messages 123 through 145 (a maximum of 100 per request), mail: >>> <[email protected]> >>> >>> To get an index with subject and author for messages 123-456 , mail: >>> <[email protected]> >>> >>> They are always returned as sets of 100, max 2000 per request, >>> so you'll actually get 100-499. >>> >>> To receive all messages with the same subject as message 12345, >>> send a short message to: >>> <[email protected]> >>> >>> The messages should contain one line or word of text to avoid being >>> treated as sp@m, but I will ignore their content. >>> Only the ADDRESS you send to is important. >>> >>> You can start a subscription for an alternate address, >>> for example "[email protected]", just add a hyphen and your >>> address (with '=' instead of '@') after the command word: >>> <[email protected]> >>> >>> To stop subscription for this address, mail: >>> <[email protected]> >>> >>> In both cases, I'll send a confirmation message to that address. When >>> you receive it, simply reply to it to complete your subscription. >>> >>> If despite following these instructions, you do not get the >>> desired results, please contact my owner at >>> [email protected]. Please be patient, my owner is a >>> lot slower than I am ;-) >>> >>> --- Enclosed is a copy of the request I received. >>> >>> Return-Path: <[email protected]> >>> Received: (qmail 97112 invoked by uid 99); 4 Jun 2015 17:26:27 -0000 >>> Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) >>> by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Jun 2015 17:26:27 >>> +0000 >>> Received: from localhost (localhost [127.0.0.1]) >>> by spamd1-us-west.apache.org (ASF Mail Server at >>> spamd1-us-west.apache.org) with ESMTP id 47645CB606 >>> for <user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang= >>> [email protected]>; Thu, 4 Jun 2015 17:26:27 +0000 (UTC) >>> X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org >>> X-Spam-Flag: NO >>> X-Spam-Score: 2.88 >>> X-Spam-Level: ** >>> X-Spam-Status: No, score=2.88 tagged_above=-999 required=6.31 >>> tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, >>> HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, >>> SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled >>> Authentication-Results: spamd1-us-west.apache.org (amavisd-new); >>> dkim=pass (2048-bit key) header.d=gmail.com >>> Received: from mx1-us-west.apache.org ([10.40.0.8]) >>> by localhost (spamd1-us-west.apache.org [10.40.0.7]) >>> (amavisd-new, port 10024) >>> with ESMTP id euvYYaufNvU8 >>> for <user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang= >>> [email protected]>; >>> Thu, 4 Jun 2015 17:26:22 +0000 (UTC) >>> Received: from mail-ig0-f182.google.com (mail-ig0-f182.google.com >>> [209.85.213.182]) >>> by mx1-us-west.apache.org (ASF Mail Server at >>> mx1-us-west.apache.org) with ESMTPS id 3DACF275E3 >>> for <user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang= >>> [email protected]>; Thu, 4 Jun 2015 17:26:22 +0000 (UTC) >>> Received: by igbzc4 with SMTP id zc4so14034401igb.0 >>> for <user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang= >>> [email protected]>; Thu, 04 Jun 2015 10:26:21 -0700 (PDT) >>> DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; >>> d=gmail.com; s=20120113; >>> >>> h=mime-version:in-reply-to:references:date:message-id:subject:from:to >>> :content-type; >>> bh=jCSYooUYuk4wmxJb795WdSFxPiK/LwY/6lOcqzPoBJo=; >>> >>> b=yu6myf9wL4fQ2HktgrhpKjBxUzfkzzPvVht1SNTDohJJSXXr8ye6R5SEGKVdQZhFrJ >>> >>> KgUEsWgweS4xxPjeS1MwKe0Rf8M1gPBG79uM1098ZffPWkYA0jlVwCMHexxNO8SOCBce >>> >>> H6VOGfRTIcDrUY+QyxPW1aPyeFJSNdUhlBgbhqYYWUDXeiXIB2PULWDGxnynMEnHAmJs >>> >>> Fma93iNeEKoYdn38Lt1j/bxuUKFEyYNEJ6Nn6HtA/lpOGfJmwLqeN9HqTj/a2vzP/+1L >>> >>> siCCCBkN/DLnnULiOXOCB2FryvVOmlF5io8bIJHM74FPTw5VwOgXLZmKfbMjyCEmsiB9 >>> YT1Q== >>> MIME-Version: 1.0 >>> X-Received: by 10.42.203.4 with SMTP id >>> fg4mr5604953icb.52.1433438781759; Thu, >>> 04 Jun 2015 10:26:21 -0700 (PDT) >>> Received: by 10.107.12.140 with HTTP; Thu, 4 Jun 2015 10:26:21 -0700 >>> (PDT) >>> In-Reply-To: <[email protected]> >>> References: <[email protected]> >>> Date: Thu, 4 Jun 2015 10:26:21 -0700 >>> Message-ID: < >>> cakguhllnnn3n6n7hkfewy0em+6x8pkgvpwjaffja0wupb7v...@mail.gmail.com> >>> Subject: Re: confirm subscribe to [email protected] >>> From: Hawin Jiang <[email protected]> >>> To: user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang= >>> [email protected] >>> Content-Type: multipart/alternative; >>> boundary=20cf303f640664e8300517b47994 >>> >>> >> >
