flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hawin Jiang <hawin.ji...@gmail.com>
Subject Re: WELCOME to user@flink.apache.org
Date Thu, 04 Jun 2015 17:49:03 GMT
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 <rmetzger@apache.org> wrote:

> Yes, I've got this message.
>
> On Thu, Jun 4, 2015 at 7:42 PM, Hawin Jiang <hawin.jiang@gmail.com> 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, <user-help@flink.apache.org> wrote:
>>
>>> Hi! This is the ezmlm program. I'm managing the
>>> user@flink.apache.org mailing list.
>>>
>>> Acknowledgment: I have added the address
>>>
>>>    hawin.jiang@gmail.com
>>>
>>> to the user mailing list.
>>>
>>> Welcome to user@flink.apache.org!
>>>
>>> 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:
>>>    <user-subscribe@flink.apache.org>
>>>
>>> To remove your address from the list, send a message to:
>>>    <user-unsubscribe@flink.apache.org>
>>>
>>> Send mail to the following for info and FAQ for this list:
>>>    <user-info@flink.apache.org>
>>>    <user-faq@flink.apache.org>
>>>
>>> Similar addresses exist for the digest list:
>>>    <user-digest-subscribe@flink.apache.org>
>>>    <user-digest-unsubscribe@flink.apache.org>
>>>
>>> To get messages 123 through 145 (a maximum of 100 per request), mail:
>>>    <user-get.123_145@flink.apache.org>
>>>
>>> To get an index with subject and author for messages 123-456 , mail:
>>>    <user-index.123_456@flink.apache.org>
>>>
>>> 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:
>>>    <user-thread.12345@flink.apache.org>
>>>
>>> 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 "john@host.domain", just add a hyphen and your
>>> address (with '=' instead of '@') after the command word:
>>> <user-subscribe-john=host.domain@flink.apache.org>
>>>
>>> To stop subscription for this address, mail:
>>> <user-unsubscribe-john=host.domain@flink.apache.org>
>>>
>>> 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
>>> user-owner@flink.apache.org. Please be patient, my owner is a
>>> lot slower than I am ;-)
>>>
>>> --- Enclosed is a copy of the request I received.
>>>
>>> Return-Path: <hawin.jiang@gmail.com>
>>> 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=
>>> gmail.com@flink.apache.org>; 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=
>>> gmail.com@flink.apache.org>;
>>>         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=
>>> gmail.com@flink.apache.org>; Thu,  4 Jun 2015 17:26:22 +0000 (UTC)
>>> Received: by igbzc4 with SMTP id zc4so14034401igb.0
>>>         for <user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang=
>>> gmail.com@flink.apache.org>; 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: <1433437918.33026.ezmlm@flink.apache.org>
>>> References: <1433437918.33026.ezmlm@flink.apache.org>
>>> Date: Thu, 4 Jun 2015 10:26:21 -0700
>>> Message-ID: <
>>> CAKgUhLLNNn3n6n7hkFEwY0eM+6X8pkgvpwJAFfJA0Wupb7vu+w@mail.gmail.com>
>>> Subject: Re: confirm subscribe to user@flink.apache.org
>>> From: Hawin Jiang <hawin.jiang@gmail.com>
>>> To: user-sc.1433437918.albpnfpfnnoeccpehlmm-hawin.jiang=
>>> gmail.com@flink.apache.org
>>> Content-Type: multipart/alternative;
>>> boundary=20cf303f640664e8300517b47994
>>>
>>>
>>
>

Mime
View raw message