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

Hi Flavio, Thanks this script is very useful, however we need Flink scala script to load data from csv to postgress. if we have following java equivalent code in scala that will be really helpful...thanks. myResult.output( // build and configure OutputFormat

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

Hi Jagan, I have a Java version of such a Job if you want (that requires table-api in order to handle null values), I hope this could help! Obviously you'll have to set all parameters properly..(e.g. jdbcOutputFormat , fieldTypes, etc...). public static void main(String[] args) throws Exception

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

Hi Guys, We have requirement like – loading data from local CSV file to Postgress database using Flink Scala… Do you have any sample Flink scala code for this? We have tried and searched in Google/Flinkweb website for data load, we haven’t found any sample code for this requisite. Code: Flink

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

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: >

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

Thanks Suneel, but client want to implement the data load in Flink Scala.. On 22 September 2016 at 20:07, Suneel Marthi wrote: > Couldn't u use SQLLoader or something for doing that? > > http://stackoverflow.com/questions/2987433/how-to- >

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

Couldn't u use SQLLoader or something for doing that? http://stackoverflow.com/questions/2987433/how-to-import-csv-file-data-into-a-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