Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 7BAFB182BB for ; Mon, 17 Aug 2015 09:28:14 +0000 (UTC) Received: (qmail 56258 invoked by uid 500); 17 Aug 2015 09:28:14 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 56184 invoked by uid 500); 17 Aug 2015 09:28:14 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 56174 invoked by uid 99); 17 Aug 2015 09:28:14 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 Aug 2015 09:28:14 +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 C12AAC0856 for ; Mon, 17 Aug 2015 09:28:13 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.982 X-Spam-Level: ** X-Spam-Status: No, score=2.982 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, 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-us-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 9Rxc48gvaY86 for ; Mon, 17 Aug 2015 09:28:03 +0000 (UTC) Received: from mail-vk0-f41.google.com (mail-vk0-f41.google.com [209.85.213.41]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 6E3E2205B4 for ; Mon, 17 Aug 2015 09:28:03 +0000 (UTC) Received: by vkbg64 with SMTP id g64so38897483vkb.0 for ; Mon, 17 Aug 2015 02:28:01 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:date:message-id:subject :from:to:content-type; bh=y6MrwY2BgM6ab3z8ZxISk0PSq0CbUHZE00vHF3/FVZ4=; b=BlKRrwNcyrGUZ3WfRO8LkrkOM2OO+vddiSS4aCMIydM1BhzEQqxvJRfU8UgQ4LR2PH 11QdOhJEMdstKv3pSuGVAxtNCnPT3r4Phmz7Ali7EtTnxjSjB9fG24maOWq/WjfxDvM7 xDJ40EWQVjKD/j0RIy2i33GReTJF5aRDuvCGnqXZPSVWrR0rcCRe2Jf1zd6Mj6Pfoacp aCJ16OJ5PsdABTfF8LL4sl2gmm4lH/Lf49gehvcl8Qk7nypBQieNhrYfrH4woPkzoV/T ACsANK4SE2AhHb8eY4IehYy4gA2+Cpe+2UDTt9mXDHRs34anRUYzsEo5A4H/Q04P4yWz P7hA== MIME-Version: 1.0 X-Received: by 10.52.143.167 with SMTP id sf7mr460067vdb.36.1439803681816; Mon, 17 Aug 2015 02:28:01 -0700 (PDT) Sender: ewenstephan@gmail.com Received: by 10.31.128.19 with HTTP; Mon, 17 Aug 2015 02:28:01 -0700 (PDT) In-Reply-To: References: Date: Mon, 17 Aug 2015 11:28:01 +0200 X-Google-Sender-Auth: uRNdHhTsNwfNeQKWPF54sOYRoxU Message-ID: Subject: Re: DataSource vs DataSet From: Stephan Ewen To: user@flink.apache.org Content-Type: multipart/alternative; boundary=047d7b5d5fd60044a5051d7e6b5a --047d7b5d5fd60044a5051d7e6b5a Content-Type: text/plain; charset=UTF-8 Hi! They are really the same. The DataSource is the subclass of DataSet which is used when sou do a source operation (env.readTextFile(...) returns a DataSource for example). Greetings, Stephan On Mon, Aug 17, 2015 at 11:23 AM, Flavio Pompermaier wrote: > Hi flinkers, > I have a very simple question for you after the reading of the amazing > blog page posted by Nezih Yigitbasi at http://t.co/dCDfFf6DhW (that shows > how to integrate Flink and Avro-Parquet through Kite SDK). > > Is there any code style policy about when to use DataSource or when to use > DataSet as the type of an input source? I usually use DataSet but I could > use DataSource as well..is there any reason to prefer the first over the > second? > > Best, > Flavio > --047d7b5d5fd60044a5051d7e6b5a Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi!

They are really the same. The DataS= ource is the subclass of DataSet which is used when sou do a source operati= on (env.readTextFile(...) returns a DataSource for example).

=
Greetings,
Stephan


On Mon, Aug 17, 2015 at 11= :23 AM, Flavio Pompermaier <pompermaier@okkam.it> wrote:<= br>
Hi flinkers,
I have a= very simple question for you after the reading of the amazing blog page po= sted by Nezih Yigitbasi at http://t.co/dCDfFf6DhW (that shows how to integrate Flink and Avro= -Parquet through Kite SDK).

Is there any code style = policy about when to use DataSource or when to use DataSet as the type of a= n input source? I usually use DataSet but I could use DataSource as well..i= s there any reason to prefer the first over the second?=C2=A0
Best,
Flavio

--047d7b5d5fd60044a5051d7e6b5a--