Return-Path: X-Original-To: apmail-spark-user-archive@minotaur.apache.org Delivered-To: apmail-spark-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 8A0D711F83 for ; Tue, 26 Aug 2014 12:42:49 +0000 (UTC) Received: (qmail 66247 invoked by uid 500); 26 Aug 2014 12:42:47 -0000 Delivered-To: apmail-spark-user-archive@spark.apache.org Received: (qmail 66191 invoked by uid 500); 26 Aug 2014 12:42:47 -0000 Mailing-List: contact user-help@spark.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@spark.apache.org Received: (qmail 66181 invoked by uid 99); 26 Aug 2014 12:42:47 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Aug 2014 12:42:47 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of raviprincesharma@gmail.com designates 209.85.192.45 as permitted sender) Received: from [209.85.192.45] (HELO mail-qg0-f45.google.com) (209.85.192.45) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Aug 2014 12:42:16 +0000 Received: by mail-qg0-f45.google.com with SMTP id f51so14499248qge.18 for ; Tue, 26 Aug 2014 05:42:15 -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=Z5th9jKtiLdgmoQasDtM9qy69S7ajgeyfemU3rNrUp8=; b=yq5osJ3NLujfJHfK+nadGXf7vvd2eZgFxWvGnf5EUOGB9C9PyVdCPSsP4E8WzMlkv7 hq8ca9pBjESfYGJckzMwpjUapYNcOvZdrzwywC+WHVXVPTqhKOY80vBW+enLlpCI23wa 0qXhKHZcjurpwSRBIoX6gxAPzywM1yzIaXQSKyxSNLI6kyhz75qG8NSnq8IqDR3fzsCn lZdO6waJPaRjWj/HuxujR0BbK0cOqT3Xcp38BikqEbt3KNva81PGbXVkvYhd5+/cPlLr fkVpu3/ATVlrl7Pu9sF2VBNe1l3D+5riV84pS/2jDNLhxOOzBFcq10joVpDVofiA93q4 RGMw== MIME-Version: 1.0 X-Received: by 10.224.15.81 with SMTP id j17mr24932860qaa.20.1409056935147; Tue, 26 Aug 2014 05:42:15 -0700 (PDT) Received: by 10.224.26.10 with HTTP; Tue, 26 Aug 2014 05:42:15 -0700 (PDT) In-Reply-To: References: Date: Tue, 26 Aug 2014 18:12:15 +0530 Message-ID: Subject: Re: Spark Streaming Output to DB From: Ravi Sharma To: user@spark.apache.org Content-Type: multipart/alternative; boundary=047d7bdc774616bb5e050187a2d4 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bdc774616bb5e050187a2d4 Content-Type: text/plain; charset=UTF-8 > > Hello People, > > I'm using java spark streaming. I'm just wondering, Can I make simple jdbc > connection in JavaDStream map() method? > > Or > > Do I need to create jdbc connection for each JavaPairDStream, after map > task? > > Kindly give your thoughts. > > > Cheers, > Ravi Sharma > --047d7bdc774616bb5e050187a2d4 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hello People,
I'm using java spark streaming. I'm just wondering, Can I make simp= le jdbc connection in JavaDStream map() method?

Or=

Do =C2=A0I need to create jdbc connection for each JavaPairDStre= am, after map task?

Kindly give your thoughts.
=


Cheers,
Ravi Sharma

--047d7bdc774616bb5e050187a2d4--