Make use of compagnion object constructor

Author: parisni

README.rst

@@ -38,13 +38,13 @@ Usage
 	// the connection looks into /home/$USER/.pgpass for a password
 	val url = "jdbc:postgresql://somehost:someport/somedb?user=someuser&currentSchema=someschema"
 
-        val pg = new PGUtil(sparkSession, url, "spark-postgres-tmp" ) // specify a temporary folder in hdfs or locally
+        val pg = PGUtil(sparkSession, url, "spark-postgres-tmp" ) // specify a temporary folder in hdfs or locally
         val df = pg
           .tableDrop("person_tmp") // drop table if exists
           .tableCopy("person","person_tmp") // duplicate the table without data
           .inputBulk(query="select * from person",  numPartitions=4, partitionColumn="person_id") // get a df from the table
 
-        pg.outputBulk("person_tmp", df) // load the new table with the df
+        pg.outputBulk("person_tmp", df, numPartitions=4) // load the new table with the df with 4 thread
           .tableDrop("person_tmp") // drop the temparary table
           .purgeTmp() // purge the temporary folder
 

pom.xml

@@ -2,7 +2,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>fr.aphp.wind.spark</groupId>
   <artifactId>spark-postgres</artifactId>
-  <version>2.1.1-SNAPSHOT</version>
+  <version>2.2.0-SNAPSHOT</version>
   <packaging>jar</packaging>
   <url>https://github.com/EDS-APHP/spark-postgres</url>
   <name>spark-postgres</name>

src/main/scala/PGUtil.scala

@@ -107,7 +107,7 @@ class PGUtil(spark:SparkSession, url: String, tmpPath:String) {
 
 object PGUtil extends java.io.Serializable {
 
-   def apply(spark: SparkSession, url: String, tmpPath:String):PGUtil = new PGUtil(spark, url, tmpPath + randomUUID.toString)
+   def apply(spark: SparkSession, url: String, tmpPath:String):PGUtil = new PGUtil(spark, url, tmpPath + randomUUID.toString).setPassword("")
 
    private def dbPassword(hostname:String, port:String, database:String, username:String ):String = {
     // Usage: val thatPassWord = dbPassword(hostname,port,database,username)