Return-Path: 
 <user-return-962-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
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 3589F17E22
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Sat, 11 Apr 2015 14:38:54 +0000 (UTC)
Received: (qmail 41459 invoked by uid 500); 11 Apr 2015 14:38:54 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 41394 invoked by uid 500); 11 Apr 2015 14:38:54 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 41383 invoked by uid 99); 11 Apr 2015 14:38:54 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 11 Apr 2015 14:38:54 +0000
X-ASF-Spam-Status: No, hits=3.2 required=5.0
	tests=FORGED_YAHOO_RCVD,FREEMAIL_ENVFROM_END_DIGIT,SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: error (nike.apache.org: encountered temporary error during SPF
 processing of domain of loveallah1987@yahoo.com)
Received: from [162.253.133.43] (HELO mwork.nabble.com) (162.253.133.43)
    by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 11 Apr 2015 14:38:28 +0000
Received: from mjoe.nabble.com (unknown [162.253.133.57])
	by mwork.nabble.com (Postfix) with ESMTP id 040721A8B788
	for <user@flink.incubator.apache.org>; Sat, 11 Apr 2015 07:38:05 -0700 (PDT)
Date: Sat, 11 Apr 2015 07:24:47 -0700 (PDT)
From: hagersaleh <loveallah1987@yahoo.com>
To: user@flink.incubator.apache.org
Message-ID: <1428762287176-982.post@n4.nabble.com>
Subject: How can generation dataset in flink automatic depend on number of
 filed and data type
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

I want write program flink on any database
user input filed and type of filed and
when read database want generate  automatic function  dataset

any example in flink i want database and write function to handles this
example
final ExecutionEnvironment env =
ExecutionEnvironment.getExecutionEnvironment();

                // get input data
                DataSet<Lineitem> lineitems = getLineitemDataSet(env);
                DataSet<Order> orders = getOrdersDataSet(env);
                DataSet<Customer> customers = getCustomerDataSet(env);


        //
*************************************************************************
        //     DATA TYPES
        //
*************************************************************************
       
        public static class Lineitem extends Tuple4<Long, Double, Double,
String> {

                public Long getOrderkey() { return this.f0; }
                public Double getDiscount() { return this.f2; }
                public Double getExtendedprice() { return this.f1; }
                public String getShipdate() { return this.f3; }
        }

        public static class Customer extends Tuple2<Long, String> {
               
                public Long getCustKey() { return this.f0; }
                public String getMktsegment() { return this.f1; }
        }

        public static class Order extends Tuple4<Long, Long, String, Long> {
               
                public Long getOrderKey() { return this.f0; }
                public Long getCustKey() { return this.f1; }
                public String getOrderdate() { return this.f2; }
                public Long getShippriority() { return this.f3; }
        }

I want generate this automatic for any database and input from user 



--
View this message in context: http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/How-can-generation-dataset-in-flink-automatic-depend-on-number-of-filed-and-data-type-tp982.html
Sent from the Apache Flink (Incubator) User Mailing List archive. mailing list archive at Nabble.com.