Flink scala data sink code from CSV to postgres.

2016-09-23 Thread Jagan
Hi Guys, We have a requirement like loading data from CSV file to postgress database In Flink scala. We need very basic script how to read data from file and write it to postgress database. Could you please some one help me on that guys -- Regards. Jagan.

Re: Flink Scala - data load from CSV to postgress database.

2016-09-23 Thread Jagan
JDBCOutputFormat.buildJDBCOutputFormat() .setDrivername(" ") .setDBUrl(" ") .setQuery("insert into persons (name, age, height) values (?,?,?)") .finish() ); On 23 September 2016 at 08:35, Flavio Pompermaier wro

Re: Flink Scala - data load from CSV to postgress database.

2016-09-22 Thread Jagan
Scala. Load: from CSV to local postgres database. Thanks Jagan On 22 September 2016 at 20:37, Jagan wrote: > Hi Team, > > Will you be able to guide me on this? Is this a known issue that we > can't implement dataload in flink scala ? > >data load from

Flink Scala data load from CSV to postgress database.

2016-09-22 Thread Jagan
Google/Flinkweb website for data load, we haven’t found any sample code for this requisite. Code: Flink Scala. Load: from CSV to local postgres database. Thanks Jagan 0044-7411239688

Re: Flink Scala - data load from CSV to postgress database.

2016-09-22 Thread Jagan
Hi Team, Will you be able to guide me on this? Is this a known issue that we can't implement dataload in flink scala ? data load from csv to postgress or any relational database in Flink Scala Thanks Jagan. On 22 September 2016 at 20:15, Jagan wrote: > Thanks Suneel,

Re: Flink Scala - data load from CSV to postgress database.

2016-09-22 Thread Jagan
-postgresql-table > > > > On Thu, Sep 22, 2016 at 3:01 PM, Jagan wrote: > > > Hi Guys, > > > > We have a requirement like – loading data from local CSV file to > Postgress > > database using Flink Scala…We have tried number of ways all failed > > > > Do

Fwd: Flink Scala - data load from CSV to postgress database.

2016-09-22 Thread Jagan
Google/Flinkweb website for data load, we haven’t found any sample code for this requisite. Code: Flink Scala. Load: from CSV to local postgres database. Thanks Jagan 0044-7411239688 -- Regards. Jagan